NewConnection returns a new instance of Connection.

NewSubscriber returns a new instance of Subscriber that can be used as an mq.Subscriber.

Config is a set of optional configurations to tune up the rmq connection and its retries.

Conn is a representation of an rmq connection.

DefaultAmqpDialler returns an AmqpConn implemented by streadway/amqp.

Subscriber is a rmq specific type that implements mq.Subscriber.

AmqpChannel is an implementation of the functions we need from *amqp.Channel.Its kept minimal on purpose.

AmqpConn is an interface that abstracts out functions from amqp.Conn that are needed by this library itself.

AmqpDialler is a abstraction of a dial function to obtain AmqpConn.

Connection specifies the structure for an rmq Connection.