AdjustRoutingKey makes sure the routing key is correct.

IsAMQP returns true if the broker is AMQP.

New creates new Broker instance.

NewAMQPBroker creates new AMQPBroker instance.

NewAWSSQSBroker creates new Broker instance.

NewEagerBroker creates new EagerBroker instance.

NewErrCouldNotUnmarshaTaskSignature returns new ErrCouldNotUnmarshaTaskSignature instance.

NewRedisBroker creates new RedisBroker instance.

AMQPBroker represents an AMQP broker.

AWSSQSBroker represents a AWS SQS broker There are examples on: https://docs.aws.amazon.com/sdk-for-go/v1/developer-guide/sqs-example-create-queue.html.

Broker represents a base broker structure.

EagerBroker represents an "eager" in-memory broker.

ErrCouldNotUnmarshaTaskSignature ...

RedisBroker represents a Redis broker.

EagerMode interface with methods specific for this broker.

Interface - a common interface for all brokers.

TaskProcessor - can process a delivered task This will probably always be a worker instance.