Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConnectRabbitMQ ¶
func ConnectRabbitMQ() *amqp.Connection
func PublishToQueue ¶
func PublishToQueue(conn *amqp.Connection, queueName string, msg Msg) error
func ReceiveFromQueue ¶
func ReceiveFromQueue(conn *amqp.Connection, queueName string) (<-chan Msg, error)
Types ¶
Click to show internal directories.
Click to hide internal directories.