Documentation
¶
Index ¶
- Constants
- func ConnectMq(url string) (conn *amqp.Connection, channel *amqp.Channel, err error)
- func NewExclusiveMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, ...)
- func NewMqConsumer(url, exchange, queue, rkey, ctag string, ack, durable bool) (conn *amqp.Connection, channel *amqp.Channel, deliveries <-chan amqp.Delivery, ...)
- func NewMqExchange(channel *amqp.Channel, name, _type string, durable bool) error
- func NewMqQueue(channel *amqp.Channel, exchange, queue, rkey string, durable, exclusive bool) error
- func PriorityPublish(channel *amqp.Channel, exchange, rkey string, savedisk, priority uint8, ...) error
- func Publish(channel *amqp.Channel, exchange, rkey string, msg []byte) error
Constants ¶
View Source
const ( Transient uint8 = 1 Persistent uint8 = 2 PriorityMax uint8 = 9 PriorityMin uint8 = 0 )
Variables ¶
This section is empty.
Functions ¶
func NewExclusiveMqConsumer ¶
func NewMqConsumer ¶
func NewMqExchange ¶
func NewMqQueue ¶
func PriorityPublish ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.