mq

Jun 8, 2025

Changes in this version

+ type Factory struct

+ func NewFactory(cfg config.Config, options ...FactoryOption) *Factory

+ func (factory *Factory) CreateMQ() (contract.MQ, error)

+ type FactoryOption func(*Factory)

+ func WithObserver(observer observability.Observer) FactoryOption

Jul 25, 2022

Changes in this version

+ func NewQueueConsumer(driver Driver, queueKey string, config contract.Config) (contract.Consumer, error)

+ func NewQueueProducer(driver Driver, queueKey string, config contract.Config) (contract.Producer, error)

Sep 9, 2021

Changes in this version

+ func NewQueue(driver Driver, key message.Key, config driver.Config) (driver.Interface, error)

+ type Driver string

+ const Amqp

+ const Redis

+ type MessageQueue struct