Apalis storage using Redis as a backend
async
Apalis storage using Redis as a backend
#[tokio::main]
async fn main() -> std::io::Result<()> {
let storage = RedisStorage::connect("REDIS_URL").await.unwrap();
Monitor::new()
.register(
WorkerBuilder::new(storage.clone())
.build_fn(send_email),
)
.run()
.await
}