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