queuey 0.3.0

Type-safe, macro-configured job queues on RabbitMQ with exponential backoff
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

//! The same guarantee for closure handlers: `FnHandler` does not launder a job
//! from one queue set into a worker for another.

use queuey::prelude::*;

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Queues)]
enum AppQueues {
    Emails,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Queues)]
enum OtherQueues {
    Reports,
}

#[derive(Serialize, Deserialize, Job)]
#[job(queue = AppQueues::Emails)]
struct SendEmail {
    to: String,
}

/// Belongs to `OtherQueues`, so no `AppQueues` worker may handle it.
#[derive(Serialize, Deserialize, Job)]
#[job(queue = OtherQueues::Reports, retry(max_attempts = 2))]
struct BuildReport {
    id: u64,
}

async fn wrong_queue_set(backend: Arc<MemoryBackend>) {
    let _worker = Worker::<AppQueues, _>::builder(backend)
        .handler(FnHandler::<SendEmail, _>::new(
            |_job: SendEmail, _ctx: JobContext| async move { Ok(()) },
        ))
        .handler(FnHandler::<BuildReport, _>::new(
            |_job: BuildReport, _ctx: JobContext| async move { Ok(()) },
        ))
        .build()
        .await
        .unwrap();
}

fn main() {}