Documentation ¶
Index ¶
- func Connect(conString string) (connection *amqp.Connection, conChannel *amqp.Channel)
- func ConsumeQueue(name string, autoAck bool, exclusive bool, noLocal bool, noWait bool, ...) (messages <-chan amqp.Delivery)
- func CreateQueue(name string, durable bool, del_when_unused bool, exclusive bool, noWait bool, ...) (queue amqp.Queue)
- func PublishQueue(exchange string, routingKey string, mandatory bool, immediate bool, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect(conString string) (connection *amqp.Connection, conChannel *amqp.Channel)
func ConsumeQueue ¶
func CreateQueue ¶
func PublishQueue ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.