messengers

Jul 5, 2022

Changes in this version

+ type Broker interface

+ Consume func(queueName string) (<-chan *message.Message, error)

+ Publish func(queueName string, payload message.Payload) error

+ type Messenger struct

+ func New(debug bool, broker Broker) *Messenger

+ func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error)

+ func (m *Messenger) Publish(queueName string, data []byte) error