connection

Documentation

Index

• type Connection
  • func NewConnection(options *ConnectionOptions) Connection
• type ConnectionOptions

Types

type Connection

type Connection interface {
	GetConn() *amqp.Connection
	GetChannel() *amqp.Channel
	SetReconnectHooks(...func())
}

func NewConnection

func NewConnection(options *ConnectionOptions) Connection

type ConnectionOptions

type ConnectionOptions struct {
	URI                    string
	InitialBackoffInterval time.Duration
	MaxBackoffInterval     time.Duration
}