channelmanager

Documentation

Index

• type ChannelManager
  • func NewChannelManager(connManager *connectionmanager.ConnectionManager, log logger.Logger, ...) (*ChannelManager, error)
  • func (chanManager *ChannelManager) Close() error
  • func (chanManager *ChannelManager) ConfirmSafe(noWait bool) error
  • func (chanManager *ChannelManager) ConsumeSafe(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
  • func (chanManager *ChannelManager) ExchangeDeclarePassiveSafe(name string, kind string, durable bool, autoDelete bool, internal bool, ...) error
  • func (chanManager *ChannelManager) ExchangeDeclareSafe(name string, kind string, durable bool, autoDelete bool, internal bool, ...) error
  • func (chanManager *ChannelManager) GetReconnectionCount() uint
  • func (chanManager *ChannelManager) NotifyFlowSafe(c chan bool) chan bool
  • func (chanManager *ChannelManager) NotifyPublishSafe(confirm chan amqp.Confirmation) chan amqp.Confirmation
  • func (chanManager *ChannelManager) NotifyReconnect() (<-chan error, chan<- struct{})
  • func (chanManager *ChannelManager) NotifyReturnSafe(c chan amqp.Return) chan amqp.Return
  • func (chanManager *ChannelManager) PublishSafe(exchange string, key string, mandatory bool, immediate bool, ...) error
  • func (chanManager *ChannelManager) PublishWithContextSafe(ctx context.Context, exchange string, key string, mandatory bool, ...) error
  • func (chanManager *ChannelManager) PublishWithDeferredConfirmWithContextSafe(ctx context.Context, exchange string, key string, mandatory bool, ...) (*amqp.DeferredConfirmation, error)
  • func (chanManager *ChannelManager) QosSafe(prefetchCount int, prefetchSize int, global bool) error
  • func (chanManager *ChannelManager) QueueBindSafe(name string, key string, exchange string, noWait bool, args amqp.Table) error
  • func (chanManager *ChannelManager) QueueDeclarePassiveSafe(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, ...) (amqp.Queue, error)
  • func (chanManager *ChannelManager) QueueDeclareSafe(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, ...) (amqp.Queue, error)

Types

type ChannelManager

type ChannelManager struct {
	// contains filtered or unexported fields
}

ChannelManager -

func NewChannelManager

func NewChannelManager(connManager *connectionmanager.ConnectionManager, log logger.Logger, reconnectInterval time.Duration) (*ChannelManager, error)

NewChannelManager creates a new connection manager

func (*ChannelManager) Close

func (chanManager *ChannelManager) Close() error

Close safely closes the current channel and connection

func (*ChannelManager) ConfirmSafe

func (chanManager *ChannelManager) ConfirmSafe(
	noWait bool,
) error

ConfirmSafe safely wraps the (*amqp.Channel).Confirm method

func (*ChannelManager) ConsumeSafe

func (chanManager *ChannelManager) ConsumeSafe(
	queue,
	consumer string,
	autoAck,
	exclusive,
	noLocal,
	noWait bool,
	args amqp.Table,
) (<-chan amqp.Delivery, error)

ConsumeSafe safely wraps the (*amqp.Channel).Consume method

func (*ChannelManager) ExchangeDeclarePassiveSafe

func (chanManager *ChannelManager) ExchangeDeclarePassiveSafe(
	name string, kind string, durable bool, autoDelete bool, internal bool, noWait bool, args amqp.Table,
) error

ExchangeDeclarePassiveSafe safely wraps the (*amqp.Channel).ExchangeDeclarePassive method

func (*ChannelManager) ExchangeDeclareSafe

func (chanManager *ChannelManager) ExchangeDeclareSafe(
	name string, kind string, durable bool, autoDelete bool, internal bool, noWait bool, args amqp.Table,
) error

ExchangeDeclareSafe safely wraps the (*amqp.Channel).ExchangeDeclare method

func (*ChannelManager) GetReconnectionCount

func (chanManager *ChannelManager) GetReconnectionCount() uint

GetReconnectionCount -

func (*ChannelManager) NotifyFlowSafe

func (chanManager *ChannelManager) NotifyFlowSafe(
	c chan bool,
) chan bool

NotifyFlowSafe safely wraps the (*amqp.Channel).NotifyFlow method

func (*ChannelManager) NotifyPublishSafe

func (chanManager *ChannelManager) NotifyPublishSafe(
	confirm chan amqp.Confirmation,
) chan amqp.Confirmation

NotifyPublishSafe safely wraps the (*amqp.Channel).NotifyPublish method

func (*ChannelManager) NotifyReconnect

func (chanManager *ChannelManager) NotifyReconnect() (<-chan error, chan<- struct{})

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

func (*ChannelManager) NotifyReturnSafe

func (chanManager *ChannelManager) NotifyReturnSafe(
	c chan amqp.Return,
) chan amqp.Return

NotifyReturnSafe safely wraps the (*amqp.Channel).NotifyReturn method

func (*ChannelManager) PublishSafe

func (chanManager *ChannelManager) PublishSafe(
	exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing,
) error

PublishSafe safely wraps the (*amqp.Channel).Publish method.

func (*ChannelManager) PublishWithContextSafe

func (chanManager *ChannelManager) PublishWithContextSafe(
	ctx context.Context, exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing,
) error

PublishWithContextSafe safely wraps the (*amqp.Channel).PublishWithContext method.

func (*ChannelManager) PublishWithDeferredConfirmWithContextSafe

func (chanManager *ChannelManager) PublishWithDeferredConfirmWithContextSafe(
	ctx context.Context, exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing,
) (*amqp.DeferredConfirmation, error)

func (*ChannelManager) QosSafe

func (chanManager *ChannelManager) QosSafe(
	prefetchCount int, prefetchSize int, global bool,
) error

QosSafe safely wraps the (*amqp.Channel).Qos method

func (*ChannelManager) QueueBindSafe

func (chanManager *ChannelManager) QueueBindSafe(
	name string, key string, exchange string, noWait bool, args amqp.Table,
) error

QueueBindSafe safely wraps the (*amqp.Channel).QueueBind method

func (*ChannelManager) QueueDeclarePassiveSafe

func (chanManager *ChannelManager) QueueDeclarePassiveSafe(
	name string,
	durable bool,
	autoDelete bool,
	exclusive bool,
	noWait bool,
	args amqp.Table,
) (amqp.Queue, error)

QueueDeclarePassiveSafe safely wraps the (*amqp.Channel).QueueDeclarePassive method

func (*ChannelManager) QueueDeclareSafe

func (chanManager *ChannelManager) QueueDeclareSafe(
	name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table,
) (amqp.Queue, error)

QueueDeclareSafe safely wraps the (*amqp.Channel).QueueDeclare method