activemq

Mar 11, 2024

Changes in this version

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

Dec 28, 2023

Changes in this version

+ type Consumer struct

+ func NewConsumer(cfg *config.StompConfig) *Consumer

+ func (c *Consumer) Close() error

+ func (c *Consumer) Connect(ctx context.Context) error

+ func (c *Consumer) Consume(ctx context.Context, queueName string, handler func(msg []byte) error) error