oppgave 0.1.0

A simple Redis-based task queue
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

extern crate rustc_serialize;
extern crate redis;
extern crate oppgave;

use oppgave::Queue;

#[derive(RustcDecodable, RustcEncodable, Debug)]
struct Job {
    id: u64
}

fn main() {
    let client = redis::Client::open("redis://127.0.0.1/").unwrap();
    let con = client.get_connection().unwrap();
    let worker = Queue::new("default".into(), con);

    println!("Starting worker with queue `default`");

    while let Some(task) = worker.next::<Job>() {
        if task.is_err() { continue; }

        let task = task.unwrap();

        println!("Task: {:?}", task.inner());
    }
}