rabbitmq

Documentation

Index

• func NewConsumerFactory(cfg *config.ProviderConfig) (queue.MessageQueueConsumer, error)
• type Consumer
  • func NewConsumer(cfg *config.AMQPConfig) *Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Connect() error
  • func (c *Consumer) Consume(queueName string, handler func(msg []byte) error) error

Functions

func NewConsumerFactory

func NewConsumerFactory(cfg *config.ProviderConfig) (queue.MessageQueueConsumer, error)

NewConsumerFactory returns a new RabbitMQ consumer based on the provided configuration.

Types

type Consumer

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

Consumer is the implementation of the MessageQueueConsumer interface for RabbitMQ

func NewConsumer

func NewConsumer(cfg *config.AMQPConfig) *Consumer

NewConsumer creates a new RabbitMQ consumer

func (*Consumer) Close

func (c *Consumer) Close() error

Close closes the connection to RabbitMQ

func (*Consumer) Connect

func (c *Consumer) Connect() error

Connect creates a connection to RabbitMQ and a channel

func (*Consumer) Consume

func (c *Consumer) Consume(queueName string, handler func(msg []byte) error) error

Consume consumes messages from RabbitMQ