Crate rsmq_async

This is a port of the nodejs Redis Simple Message Queue package. It is a 1-to-1 conversion using async.

use rsmq_async::{Rsmq, RsmqError};

let mut rsmq = Rsmq::new(Default::default()).await?;
 
let message = rsmq.receive_message("myqueue", None).await?;
 
if let Some(message) = message {
    rsmq.delete_message("myqueue", &message.id).await?;
}
 

Structs

Rsmq
RsmqMessage
RsmqOptions
RsmqQueueAttributes

Enums

RsmqError