amqp

Documentation

Index

• Variables
• type Channel
  • func (ch *Channel) Close() error
  • func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
  • func (ch *Channel) IsClosed() bool
• type Configuration
  • func (config Configuration) Dsn() string
• type Connection
  • func NewAMQPConnection(config Configuration, l *zap.Logger) (*Connection, error)
  • func (a *Connection) Channel() (*Channel, error)
  • func (a *Connection) Reconnect() error

Variables

var Module = fx.Module("amqp", fx.Provide(NewAMQPConnection))

Types

type Channel

type Channel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

func (*Channel) Close

func (ch *Channel) Close() error

Close ensure closed flag set

func (*Channel) Consume

func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

Consume wrap amqp.Channel.Consume, the returned delivery will end only when channel closed by developer

func (*Channel) IsClosed

func (ch *Channel) IsClosed() bool

IsClosed indicate closed by developer

type Configuration

type Configuration struct {
	Address      string
	ConsumerName string
	TLS          bool
	Username     string
	Password     string
}

func (Configuration) Dsn

func (config Configuration) Dsn() string

type Connection

type Connection struct {
	Amqp *amqp.Connection
	Log  *zap.Logger
	// contains filtered or unexported fields
}

func NewAMQPConnection

func NewAMQPConnection(config Configuration, l *zap.Logger) (*Connection, error)

func (*Connection) Channel

func (a *Connection) Channel() (*Channel, error)

func (*Connection) Reconnect

func (a *Connection) Reconnect() error