Documentation
¶
Overview ¶
Package rabbitmq implements the triton-core/amqp module
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrorEnsureExchange is returned when exchanges are unable to be created ErrorEnsureExchange = errors.New("failed to ensure exchange") // ErrorEnsureConsumerQueues is returned when consumer queues are unable to be created ErrorEnsureConsumerQueues = errors.New("failed to ensure consumer queues") )
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a RabbitMQ client
func (*Client) SetPrefetch ¶
SetPrefetch updates the prefetch of our channels
type Delivery ¶
type Delivery struct {
Metadata DeliveryMetadata
// Delivery is the internal amqp delivery struct
Delivery amqp.Delivery
// Channel this message was recieved on
Channel *amqp.Channel
}
Delivery is an AMQP delivery
func NewDelivery ¶
NewDelivery creates a delivery object
type DeliveryMetadata ¶
type DeliveryMetadata struct {
Retries int
}
DeliveryMetadata is metadata from AMQP headers
Source Files
Click to show internal directories.
Click to hide internal directories.