rabbitmq

package

v0.3.4 Latest Latest Go to latest Published: Feb 18, 2024 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Consumer is the implementation of the MessageQueueConsumer interface for RabbitMQ

func NewConsumer(cfg *config.AMQPConfig) *Consumer

NewConsumer creates a new RabbitMQ consumer

func (c *Consumer) Close() error

Close closes the connection to RabbitMQ

func (c *Consumer) Connect() error

Connect creates a connection to RabbitMQ and a channel

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

Consume consumes messages from RabbitMQ