Documentation ¶ Index ¶ type Messenger func New(debug bool, publisher *amqp.Publisher, consumer *amqp.Subscriber) *Messenger func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error) func (m *Messenger) Publish(queueName string, data []byte) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Messenger ¶ type Messenger struct { // contains filtered or unexported fields } func New ¶ added in v3.2.9 func New(debug bool, publisher *amqp.Publisher, consumer *amqp.Subscriber) *Messenger func (*Messenger) Consume ¶ func (m *Messenger) Consume(queueName string) (<-chan *message.Message, error) func (*Messenger) Publish ¶ func (m *Messenger) Publish(queueName string, data []byte) error Source Files ¶ View all Source files messenger.go Click to show internal directories. Click to hide internal directories.