amqp

package

v0.7.0 Latest Latest Go to latest Published: Jan 6, 2024 License: GPL-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

func (ch *Channel) Close() error

Close ensure closed flag set

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 (ch *Channel) IsClosed() bool

IsClosed indicate closed by developer

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

func (config Configuration) Dsn() string

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

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

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

func (a *Connection) Reconnect() error