utility

Documentation

Index

• func OpenAMQPConnection(conf config.AMQPEndpoint) (*amqp.Connection, error)
• type AMQPMessage
  • func NewAMQPMessage(maxRetries int64) AMQPMessage

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