Struct rsmq_async::Rsmq

pub struct Rsmq { /* fields omitted */ }

Methods

impl Rsmq

pub async fn new(options: RsmqOptions) -> Result<Rsmq, RsmqError>

pub async fn change_message_visibility_async<'_, '_, '_>(
    &'_ mut self,
    qname: &'_ str,
    message_id: &'_ str,
    hidden_duration: u64
) -> Result<(), RsmqError>

pub async fn create_queue_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str,
    seconds_hidden: Option<u32>,
    delay: Option<u32>,
    maxsize: Option<i32>
) -> Result<(), RsmqError>

pub async fn delete_message_async<'_, '_, '_>(
    &'_ mut self,
    qname: &'_ str,
    id: &'_ str
) -> Result<bool, RsmqError>

pub async fn delete_queue_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str
) -> Result<(), RsmqError>

pub async fn get_queue_attributes_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str
) -> Result<RsmqQueueAttributes, RsmqError>

pub async fn list_queues_async<'_>(
    &'_ mut self
) -> Result<Vec<String>, RsmqError>

pub async fn pop_message_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str
) -> Result<RsmqMessage, RsmqError>

pub async fn receive_message_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str,
    hidden_duration: Option<u64>
) -> Result<RsmqMessage, RsmqError>

pub async fn send_message_async<'_, '_, '_>(
    &'_ mut self,
    qname: &'_ str,
    message: &'_ str,
    delay: Option<u64>
) -> Result<String, RsmqError>

pub async fn set_queue_attributes_async<'_, '_>(
    &'_ mut self,
    qname: &'_ str,
    hidden_duration: Option<u64>,
    delay: Option<u64>,
    maxsize: Option<i64>
) -> Result<RsmqQueueAttributes, RsmqError>

Trait Implementations

impl Debug for Rsmq

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.