[−][src]Crate sqslisten
SQSListen, a simple listener for AWS SQS queue.
It allows you to set listener to your AWS SQS queue which will ask for the available messages in the queue and call the passed handler when the message received. Once message received and processed (does not matter if handler returns error or not) the message is removed from the queue.
Usage
use sqslisten::{ReceiveMessageRequest, Region, SQSListen}; use std::{thread, time}; fn main() { let mut sqs_listener = SQSListen::new(Region::UsEast1); let handle = sqs_listener.listen( ReceiveMessageRequest { queue_url: "<queue_url>".to_string(), ..ReceiveMessageRequest::default() }, |msg, err| { match msg { Some(message) => println!("Message received: {:?}", message), None => {} } match err { Some(error) => println!("Error received: {:?}", error), None => {} } return Ok(()); }, ); let ten_seconds = time::Duration::from_millis(100000); thread::sleep(ten_seconds); handle.stop(); }
Structs
DeleteMessageRequest | |
HandlerError | |
Message | An Amazon SQS message. |
ReceiveMessageRequest | |
ReceiveMessageResult | A list of received messages. |
SQSListen |
Enums
ReceiveMessageError | Errors returned by ReceiveMessage |
Region | An AWS region. |
RusotoError | Generic error type returned by all rusoto requests. |
Traits
DispatchSignedRequest | Trait for implementing HTTP Request/Response |
ProvideAwsCredentials | A trait for types that produce |