New creates a new consumer state instance, and automatically attempts to connect to the server.

NewChannelHost creates a simple ConnectionHost wrapper for management by end-user developer.

NewConnectionHost creates a simple ConnectionHost wrapper for management by end-user developer.

NewConnectionPool creates hosting structure for the ConnectionPool.

ErrAlreadyClosed is returned when the connection is already closed.

ErrNack is returned when a message publish fails with a NACK.

ErrNotConnected is returned when not connected to a server.

ErrPublishOnly is returned when a channel is publish only and you try and use a queue function.

ErrServerBusy is returned when there is too much tcp backpressure on a channel.

ErrShutdown is returned when already shutting down.

ErrTimedOut is returned when a message times out waiting for confirmation.

ChannelHost is an internal representation of amqp.Connection.

Config for the session.

ConnectionHost is an internal representation of amqp.Connection.

ConnectionPool houses the pool of RabbitMQ connections.

Session is the rabbitmq session.