Skip to main content

simple_queue/queue/
handler_api.rs

1use std::sync::Arc;
2
3use crate::*;
4impl SimpleQueue {
5    /// Register a job handler for a specific queue.
6    pub fn register_handler(&self, handler: impl Handler + 'static) -> &Self {
7        let queue = handler.queue();
8        self.job_registry.insert(queue, Arc::new(handler));
9        self
10    }
11}