Documentation
¶
Overview ¶
Package queue adds a topology.Declarer interface able to describe AMQP queues.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AutoDelete ¶
func AutoDelete(queue *Declarer)
AutoDelete will automatically delete the described queue if there are no more consumers subscribed to the queue.
func Durable ¶
func Durable(queue *Declarer)
Durable will make the described queue survive AMQP broker restarts.
Types ¶
type Declarer ¶
type Declarer struct {
// contains filtered or unexported fields
}
Declarer is a topology component able to declare AMQP queues. Use Declare function to create a new instance of this component.
type Option ¶
type Option func(*Declarer)
Option is an optional functionality that can be added to the Declarer that is being initialized by the Declare factory method.
func Arguments ¶
Arguments specifies optional arguments to be supplied during queue declaration. Multiple calls of this option are supported.
func BindTo ¶
BindTo describes a binding for the queue. Multiple calls of this option are supported.
func DeadLetter ¶
DeadLetter adds Dead Letter Exchange functionality to the described queue, by publishing rejected messages on the exchange and routingKey provided.
func DeadLetterWithQueue ¶
DeadLetterWithQueue declares a Dead Letter Exchange and a queue that will be binded to the specified exchange and routing key.
Useful to persist failed messages in a specified queue and consuming messages from such queue from the application with a compensating action.
func Description ¶
Description adds a description for the queue.
Source Files