Versions in this module Expand all Collapse all v0 v0.1.1 Apr 17, 2020 v0.1.0 Apr 16, 2020 Changes in this version + type Channel struct + func (_m *Channel) Close() error + func (_m *Channel) Consume(queue string, name string, autoAck bool, exclusive bool, noLocal bool, ...) (<-chan amqp.Delivery, error) + func (_m *Channel) Qos(prefetchCount int, prefetchSize int, global bool) error + type Closer struct + func (_m *Closer) Close(_a0 context.Context) error + func (_m *Closer) Closed() <-chan error + type Connection struct + func (_m *Connection) Channel() (*amqp.Channel, error) + func (_m *Connection) Close() error