rabbit

Documentation

Index

• Variables
• func Connect() bool
• func OpenChanel() bool
• func PublishWithContext(queueName string, body string)
• func QueueDeclare(name string) bool

Variables

var AmqpChanel *amqp.Channel = nil

var AmqpConnection *amqp.Connection = nil

var Context context.Context

var Queue = map[string]amqp.Queue{}

Functions

func Connect

func Connect() bool

func OpenChanel

func OpenChanel() bool

func PublishWithContext

func PublishWithContext(queueName string, body string)

func QueueDeclare

func QueueDeclare(name string) bool