listener

type Channel ¶

type Channel interface {
	io.Closer

	Qos(prefetchCount, prefetchSize int, global bool) error
	Consume(queue, name string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
}

Channel is the channel interface the Listener uses to listen and serve incoming messages.

type Closer ¶

type Closer interface {
	Close(context.Context) error
	Closed() <-chan error
}

Closer is used to stop listening from a specific Listener.

type Connection ¶

type Connection interface {
	io.Closer

	Channel() (*amqp.Channel, error)
}

Connection is the connection interface the Listener uses to listen and serve incoming messages.

type Func ¶

type Func func(Connection, Channel, handler.Handler) (Closer, error)

Func is an inline function that implements the Listener interface. Useful for mocking or stateless Listener implementations.

func (fn Func) Listen(conn Connection, ch Channel, h handler.Handler) (Closer, error)

type Listener ¶

type Listener interface {
	Listen(Connection, Channel, handler.Handler) (Closer, error)
}

Listener listens for incoming messages using an amqp.Connection or amqp.Channel provided, and calls the specified message handler to handle all incoming messages.

Returns a Closer interface to stop listening to incoming messages.

func Sink(listeners ...Listener) Listener

func UseDedicatedChannel(listener Listener) Listener