Versions in this module Expand all Collapse all v0 v0.1.0 Jan 28, 2021 Changes in this version + type Listener struct + func NewListener(addr, queue string) (*Listener, error) + func (r *Listener) Close() error + func (r *Listener) Listen() (<-chan amqp.Delivery, error) + type Publisher struct + func NewPublisher(addr, queue string) (*Publisher, error) + func (r *Publisher) Close() error + func (r *Publisher) Publish(body []byte, contentType string) error