Trait disqrust::Handler [] [src]

pub trait Handler {
    fn process_job(
        queue_name: &[u8],
        jobid: &String,
        body: Vec<u8>
    ) -> JobStatus; fn process_error(&self, _: &[u8], _: &String, _: u32, _: u32) -> bool { ... } }

Handles a job task.

Required Methods

Process a job.

Provided Methods

Decides if a job that failed in the past should be re-executed. nack is the count of negatives acknowledges. additional_deliveries is the number of times the job was processed but it was not acknowledged.