sqs_listener

Getting Started

Available on crates: crates.io/sqs_listener

Documentation available at: docs.rs/sqs_listener

toml sqs_worker = "0.1.0"

Simple Example

Simple example: /examples/simple.rs

```rust use sqs_worker::{EnvironmentVariableCredentialsProvider, SQSListener, SQSListenerClientBuilder}; use std::env;

[tokio::main]

async fn main() -> eyre::Result<()> { envlogger::init(); coloreyre::install()?;

let queue_url = env::var("QUEUE_URL").expect("QUEUE_URL env variable needs to be present");

let region = env::var("REGION").ok();

let credentials_provider = EnvironmentVariableCredentialsProvider::new();

let listener = SQSListener::new(queue_url, |message| {
    println!("Message received {:#?}", message.body())
});

let client = SQSListenerClientBuilder::new_with(region, credentials_provider)
    .listener(listener)
    .build()?;
let _ = client.start().await;

Ok(())

} ```

Start a listener using AWS creds

Example with creds: /examples/with_creds.rs

```rust use sqs_worker::{EnvironmentVariableCredentialsProvider, SQSListener, SQSListenerClientBuilder}; use std::env;

[tokio::main]

async fn main() -> eyre::Result<()> { envlogger::init(); coloreyre::install()?;

let queue_url = env::var("QUEUE_URL").expect("QUEUE_URL env variable needs to be present");

let region = env::var("REGION").ok();

let credentials_provider = EnvironmentVariableCredentialsProvider::new();

let listener = SQSListener::new(queue_url, |message| {
    println!("Message received {:#?}", message.body())
});

let client = SQSListenerClientBuilder::new_with(region, credentials_provider)
    .listener(listener)
    .build()?;
let _ = client.start().await;

Ok(())

} ```