queue

Documentation

Index

• func CloseConsumer(consumer Consumer, log logger.Logger)
• type Consumer
  • func NewConsumer(conf config.QueueConfig, log logger.Logger) (Consumer, error)
• type Listener
  • func NewListener() Listener
• type ListenerImpl
  • func (listener *ListenerImpl) Start(ctx context.Context, consumer Consumer, config *config.QueueConfig, ...) error

Functions

func CloseConsumer

func CloseConsumer(consumer Consumer, log logger.Logger)

Types

type Consumer

type Consumer interface {
	io.Closer
	StartConsuming(
		handler rabbitmq.Handler,
		queue string,
		routingKeys []string,
		optionFuncs ...func(*rabbitmq.ConsumeOptions),
	) error
}

Consumer is just an interface for the library consumer which doesn't have one.

func NewConsumer

func NewConsumer(conf config.QueueConfig, log logger.Logger) (Consumer, error)

type Listener

type Listener interface {
	//Start listening queues
	Start(
		ctx context.Context,
		consumer Consumer,
		config *config.QueueConfig,
		handler handler.Handler,
	) error
}

Listener represents the consumer wrapper with the method to start listening for all events for this service

func NewListener

func NewListener() Listener

type ListenerImpl

type ListenerImpl struct {
}

func (*ListenerImpl) Start

func (listener *ListenerImpl) Start(
	ctx context.Context,
	consumer Consumer,
	config *config.QueueConfig,
	handler handler.Handler,
) error