simple/
simple.rs

1use sqs_worker::{SQSListener, SQSListenerClientBuilder};
2use std::env;
3
4#[tokio::main]
5async fn main() -> eyre::Result<()> {
6    env_logger::init();
7    color_eyre::install()?;
8
9    let queue_url = env::var("QUEUE_URL").unwrap_or("".to_string());
10
11    let region = env::var("REGION").ok();
12
13    let listener = SQSListener::new(queue_url, |message| {
14        println!("Message received {:#?}", message)
15    });
16    let client = SQSListenerClientBuilder::new(region)
17        .listener(listener)
18        .build()?;
19    let _ = client.start().await;
20    Ok(())
21}
simple/simple.rs

simple/
simple.rs
