activemq

Documentation

Index

• func NewConsumerFactory(cfg *config.ProviderConfig) (queue.MessageQueueConsumer, error)
• type Consumer
  • func NewConsumer(cfg *config.StompConfig) *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
}

func NewConsumer

func NewConsumer(cfg *config.StompConfig) *Consumer

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Connect

func (c *Consumer) Connect() error

func (*Consumer) Consume

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