rabbitmq

Feb 5, 2025

Changes in this version

+ func AddQueueMapper(rmq *RabbitMQ, queues QueueMapper) error

+ type QueueMapper map[messages.Key]*Recipient

Dec 14, 2024

Changes in this version

type RabbitMQ

+ ConsumeCycle context.Context

+ func (r *RabbitMQ) Consume(key events.Key, queue *Recipient, deliveries <-chan amqp.Delivery, ...)

Nov 17, 2024

Changes in this version

+ type Events = map[events.Key][]events.Consumer

+ type Queues = map[events.Key]*Recipient

type RabbitMQ

+ func (r *RabbitMQ) AddExchange(name string) error

+ func (r *RabbitMQ) AddQueueEventBind(queue events.Recipient, bindingKey, routingKey events.Key, ...) error

+ func (r *RabbitMQ) Publish(event *events.Event) error

+ func (r *RabbitMQ) Subscribe(key events.Key, consumer events.Consumer) error

+ func (r *RabbitMQ) Unmarshal(data []byte, attributes, meta reflect.Type, event *events.Event) error

+ type Recipient struct

+ Attributes reflect.Type

+ BindingKey events.Key

+ Meta reflect.Type

+ Name events.Recipient

Jul 30, 2024

Changes in this version

+ func Close(session *RabbitMQ) error

+ type RabbitMQ struct

+ func Open(uri string, logger loggers.Logger) (*RabbitMQ, error)

+ func (rabbitMQ *RabbitMQ) AddQueue(queue *messages.Queue) error

+ func (rabbitMQ *RabbitMQ) AddQueueConsumer(consumer messages.Consumer) error

+ func (rabbitMQ *RabbitMQ) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error

+ func (rabbitMQ *RabbitMQ) AddRouter(router *messages.Router) error

+ func (rabbitMQ *RabbitMQ) PublishMessages(messages []*messages.Message) error