Struct Worker 

pub struct Worker<Q: QueueSet, B: Backend> { /* private fields */ }

Consumes one or more queues of Q and dispatches jobs to registered handlers.

Build one with Worker::builder; run it with Worker::run.

Implementations

impl<Q: QueueSet, B: Backend> Worker<Q, B>

pub fn builder(backend: Arc<B>) -> WorkerBuilder<Q, B>

Start configuring a worker for queue set Q on backend.

pub fn handle(&self) -> WorkerHandle

A clonable handle that can shut this worker down from anywhere.

pub fn queues(&self) -> &[QueueConfig]

The queues this worker consumes.

pub fn concurrency(&self) -> usize

Maximum number of jobs this worker runs at the same time.

pub async fn run(self) -> Result<()>

Consume and dispatch until WorkerHandle::shutdown is called.

Shutdown is graceful, and in this order:

1. the consumers stop pulling new deliveries from the broker;
2. everything they already pulled is processed normally (a delivery that has been handed over is never dropped unsettled);
3. the jobs already running are awaited.

The backend is not closed unless WorkerBuilder::close_backend_on_shutdown was set: it is usually an Arc shared with a crate::Producer that outlives the worker.

Returns Error::ConsumerStopped if a consumer stream ends on its own (which means the backend went away), or the first backend error seen on a stream.

Trait Implementations

impl<Q: QueueSet, B: Backend> Debug for Worker<Q, B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.