Struct rsmq_async::Rsmq

pub struct Rsmq { /* fields omitted */ }

Methods

impl Rsmq

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

pub fn new_with_connection(options: RsmqOptions, connection: Connection) -> Rsmq

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

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

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

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

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

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

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

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

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

pub async fn set_queue_attributes<'_, '_>(
    &'_ 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.