Struct Worker 

pub struct Worker { /* private fields */ }

Queue worker that processes jobs.

Implementations

impl Worker

pub fn new(connection: QueueConnection, config: WorkerConfig) -> Self

Create a new worker.

pub fn register<J>(&mut self)

where J: Job + DeserializeOwned + 'static,

Register a job handler.

Example

worker.register::<SendEmailJob>();

pub async fn run(&self) -> Result<(), Error>

Run the worker until shutdown.

pub fn shutdown(&self)

Signal the worker to shut down gracefully.

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.