Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OpenAMQPConnection ¶
func OpenAMQPConnection(conf config.AMQPEndpoint) (*amqp.Connection, error)
OpenAMQPConnection attempts to dial a new AMQP connection
Types ¶
type AMQPMessage ¶
type AMQPMessage interface {
CreateMessage(body interface{}) (amqp.Publishing, error)
//GetKickbackMessage takes the delivery and creates a message from it
//for requeuing on non-fatal error
GetKickbackMessage(msg amqp.Delivery) (amqp.Publishing, error)
GetNextMessage(msg amqp.Delivery, body interface{}) (amqp.Publishing, error)
}
AMQPMessage contains utilities for manipulating AMQP messages
func NewAMQPMessage ¶
func NewAMQPMessage(maxRetries int64) AMQPMessage
NewAMQPMessage creates a new AMQPMessage
Source Files
Click to show internal directories.
Click to hide internal directories.