Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustPublish ¶
MustPublish can be used as a wrapper around `PublishAndWait` and `NackDelayed` methods if you didn't want to process error and state separately.
Types ¶
type Channel ¶
Channel is a wrapper around async AMQP channel
func SyncChannel ¶
SyncChannel returns channel wrapper
func (*Channel) ConsumeMessages ¶
func (c *Channel) ConsumeMessages(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan Delivery, error)
ConsumeMessages returns chan of wrapped messages from queue
func (*Channel) PublishAndWait ¶
func (c *Channel) PublishAndWait(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) (State, error)
PublishAndWait sends message to queue and waits for response
func (*Channel) WithTimeout ¶
WithTimeout sets publish wait timeout
type Delivery ¶
Delivery is a superset of amqp.Delivery
func (*Delivery) NackDelayed ¶
NackDelayed nacks message without requeue and publishes it again without modification back to tail of queue
Click to show internal directories.
Click to hide internal directories.