utility

package
Version: v1.8.20 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL