WithConsumerTimeout sets the maximum amount of time in RabbitMQ will wait for a message ack before from a consumer before deeming the message undelivered and shuting down the connection.

WithDurableQueues sets the durable flag upon queue creation.

WithHeartbeatTTL sets the TTL for a heartbeat pending in the queue.

The queue used by workers to send tasks to when a task completes successfully.

The default queue for tasks.

The queue used by workers to send tasks to when an error occurs in processing.

The prefix used for queues that are exclusive.

The queue used by workers to periodically notify the coordinator about their aliveness.

The queue used by for job creation and job-related state changes (e.g.

The queue used by workers to send task logs to the Coordinator.

The queue used by the API to insert new tasks into.

The queue used by workers to send task progress to the Coordinator.

The queue used by workers to notify the coordinator that a task has began processing.

InMemoryBroker a very simple implementation of the Broker interface which uses in-memory channels to exchange messages.

Broker is the message-queue, pub/sub mechanism used for delivering tasks.