[−][src]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 |