Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer func(Message)
Consumer is a function that takes a amqp.Delivery struct as parameter
type MessageBroker ¶
MessageBroker holds RabbitMQ connections.
func NewMessageBroker ¶
func NewMessageBroker(amqpURL, queue string) (*MessageBroker, error)
NewMessageBroker tries to instantiate a new MessageBroker. This MessageBroker can consume messages from or send messages to a queue.
func (*MessageBroker) Listen ¶
func (mb *MessageBroker) Listen(consumer Consumer) error
Listen permits to consume messages from the declared queue. The message has to be acknowledged
Click to show internal directories.
Click to hide internal directories.