NewAMQPBroker creates a new AMQPBroker.

NewBroker creates a new Broker based on the given URI.

NewJob creates a new Job with default values, a new unique ID and current timestamp.

Creates a new Broker for an in-memory queue.

PriorityLow represents a low priority level.

PriorityNormal represents a normal priority level.

PriorityUrgent represents an urgent priority level.

ErrAlreadyClosed is the error returned when trying to close an already closed connection.

ErrEmptyJob is the error returned when an empty job is published.

ErrTxNotSupported is the error returned when the transaction receives a callback does not know how to handle.

ErrUnsupportedProtocol is the error returned when a Broker does not know how to connect to a given URL.

AMQPAcknowledger implements the Acknowledger for AMQP.

AMQPBroker implements the Broker interface for AMQP.

AMQPJobIter implements the JobIter interface for AMQP.

AMQPQueue implements the Queue interface for the AMQP.

Job contains the information for a job to be published to a queue.

Acknowledger represents the object in charge of acknowledgement management for a job.

Broker represents a message broker.

JobIter represents an iterator over a set of Jobs.

Queue represents a message queue.

Priority represents a priority level.

RepublishConditionFunc is a function used to filter jobs to republish.

TxCallback is a function to be called in a transaction.