rustqueue 0.2.0

Background jobs without infrastructure — embeddable job queue with zero external dependencies
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

//! Long-running worker that processes jobs as they arrive.
//!
//! Run with: `cargo run --example worker`
//!
//! In a second terminal, push jobs:
//!   cargo run --example basic

use rustqueue::RustQueue;
use std::time::Duration;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let rq = RustQueue::redb("/tmp/rustqueue-worker.db")?.build()?;

    println!("Worker started. Waiting for jobs on 'emails' queue...");
    println!("Push jobs with: cargo run --example basic\n");

    loop {
        let jobs = rq.pull("emails", 5).await?;

        if jobs.is_empty() {
            tokio::time::sleep(Duration::from_millis(500)).await;
            continue;
        }

        for job in &jobs {
            println!("[{}] Processing: {} — {}", job.queue, job.name, job.data);

            // Simulate work
            tokio::time::sleep(Duration::from_millis(100)).await;

            rq.ack(job.id, None).await?;
            println!("[{}] Done: {}", job.queue, job.id);
        }
    }
}