rabbit

func AssertQueue ¶

func AssertQueue(conn *amqp.Connection, queueName string)

func DeleteQueue ¶

func DeleteQueue(conn *amqp.Connection, queueName string)

func GetConnection ¶

func GetConnection() *amqp.Connection

Returns the connection to RabbitMq. If the connection is not established, will attempt to establish it, with a specified timeout period

func GetQueueChannel ¶

func GetQueueChannel(queueName string) <-chan amqp.Delivery

func PublishMessage ¶

func PublishMessage(queueName string, data []byte)