use ruststream::runtime::{AppInfo, HandlerResult, RustStream};
use ruststream::subscriber;
use ruststream_fred::{RedisBroker, RedisList};
use serde::Deserialize;
#[derive(Debug, Deserialize)]
struct Job {
id: u64,
}
#[subscriber(
RedisList::new("jobs.dlq")
.reliable()
.dead_letter("jobs.failed")
.max_deliveries(5)
)]
async fn handle_job(job: &Job) -> HandlerResult {
if job.id == 0 {
return HandlerResult::Nack { requeue: true };
}
println!("processed job {}", job.id);
HandlerResult::Ack
}
#[ruststream::app]
fn app() -> RustStream {
RustStream::new(AppInfo::new("jobs", "0.1.0")).with_broker(
RedisBroker::standalone("redis://localhost:6379"),
|b| {
b.include(handle_job);
},
)
}