Documentation
¶
Index ¶
- func DeclareQueue(conn *amqp.Connection, queueName string) error
- func MakeRabbitChannel(config mq.Config) (*amqp.Channel, error)
- func PublishMessage(body []byte, c *amqp.Channel, queue string, assert *assert.Assertions) bool
- func Wait(rabbitCfg mq.Config, timeout time.Duration) (*amqp.Connection, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeclareQueue ¶
func DeclareQueue(conn *amqp.Connection, queueName string) error
func PublishMessage ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.