connectionmanager

Documentation

Index

• type ConnectionManager
  • func NewConnectionManager(url string, conf amqp.Config, log logger.Logger, ...) (*ConnectionManager, error)
  • func (connManager *ConnectionManager) CheckinConnection()
  • func (connManager *ConnectionManager) CheckoutConnection() *amqp.Connection
  • func (connManager *ConnectionManager) Close() error
  • func (connManager *ConnectionManager) GetReconnectionCount() uint
  • func (connManager *ConnectionManager) NotifyBlockedSafe(receiver chan amqp.Blocking) chan amqp.Blocking
  • func (connManager *ConnectionManager) NotifyReconnect() (<-chan error, chan<- struct{})

Types

type ConnectionManager

type ConnectionManager struct {
	ReconnectInterval time.Duration
	// contains filtered or unexported fields
}

ConnectionManager -

func NewConnectionManager

func NewConnectionManager(url string, conf amqp.Config, log logger.Logger, reconnectInterval time.Duration) (*ConnectionManager, error)

NewConnectionManager creates a new connection manager

func (*ConnectionManager) CheckinConnection

func (connManager *ConnectionManager) CheckinConnection()

CheckinConnection -

func (*ConnectionManager) CheckoutConnection

func (connManager *ConnectionManager) CheckoutConnection() *amqp.Connection

CheckoutConnection -

func (*ConnectionManager) Close

func (connManager *ConnectionManager) Close() error

Close safely closes the current channel and connection

func (*ConnectionManager) GetReconnectionCount

func (connManager *ConnectionManager) GetReconnectionCount() uint

GetReconnectionCount -

func (*ConnectionManager) NotifyBlockedSafe

func (connManager *ConnectionManager) NotifyBlockedSafe(
	receiver chan amqp.Blocking,
) chan amqp.Blocking

NotifyBlockedSafe safely wraps the (*amqp.Connection).NotifyBlocked method

func (*ConnectionManager) NotifyReconnect

func (connManager *ConnectionManager) NotifyReconnect() (<-chan error, chan<- struct{})

NotifyReconnect adds a new subscriber that will receive error messages whenever the connection manager has successfully reconnected to the server