Struct WorkerHandle 

pub struct WorkerHandle { /* private fields */ }

Remote control for a running Worker. Cheap to clone and send across tasks.

Implementations

impl WorkerHandle

pub fn shutdown(&self)

Ask the worker to stop. Returns immediately; Worker::run finishes the jobs that are already running before it returns.

Calling this more than once, or before Worker::run starts, is fine.

pub fn is_shutdown(&self) -> bool

Whether WorkerHandle::shutdown has been called.

pub fn settle_failures(&self) -> u64

How many times the worker failed to ack / retry / dead-letter a delivery.

Each failure is also logged at ERROR. The job itself ran; only telling the broker about the outcome failed, so the message is still owned by the broker and will be redelivered. A non-zero (and especially a growing) count means duplicate processing, and usually a sick connection. Alert on it.

Trait Implementations

impl Clone for WorkerHandle

fn clone(&self) -> WorkerHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerHandle

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

Formats the value using the given formatter.