How to use Monitor & Backend? #58

#[tokio::main]
async fn main() {
    let pool = get_pg_pool().await;
    let mut email_backend = PostgresStorage::new(&pool);
    let mut reminder_backend = PostgresStorage::new(&pool);

    let monitor = Monitor::new()
        .on_event(|ctx, event| println!("{}: {:?}", ctx.name(), event))
        .register(move |_| {
            let a = WorkerBuilder::new("email-worker")
                .backend(email_backend)
                .build(send_email_job);
            a
        })
        .register(move |_| {
            let b = WorkerBuilder::new("reminder-worker")
                .backend(reminder_backend)
                .build(send_reminder);
            b
        });

    monitor.run().await.unwrap();
}

async fn main() {
    let pool = get_pg_pool().await;
    let pool_b = get_pg_pool().await;

    let monitor = Monitor::new()
        .on_event(|ctx, event| println!("{}: {:?}", ctx.name(), event))
        .register(move |_| {
            let mut email_backend = PostgresStorage::new(&pool);
            let a = WorkerBuilder::new("email-worker")
                .backend(email_backend)
                .build(send_email_job);
            a
        })
        .register(move |_| {
            let mut reminder_backend = PostgresStorage::new(&pool_b);
            let b = WorkerBuilder::new("reminder-worker")
                .backend(reminder_backend)
                .build(send_reminder);
            b
        });

    monitor.run().await.unwrap();
}