Struct rsmq::Rsmq

pub struct Rsmq {
    pub pool: Pool<RedisConnectionManager>,
    // some fields omitted
}

Fields

pool: Pool<RedisConnectionManager>

Methods

impl Rsmq

fn new<T: IntoConnectionInfo>(
    params: T,
    name_space: &str
) -> Result<Rsmq, Error>

fn create_queue(&self, opts: Queue) -> Result<u8, Error>

fn delete_queue(&self, qname: &str) -> Result<Value, Error>

fn list_queues(&self) -> Result<Vec<String>, Error>

fn change_message_visibility(
    &self,
    qname: &str,
    msgid: &str,
    hidefor: u64
) -> Result<u64, Error>

fn send_message(
    &self,
    qname: &str,
    message: &str,
    delay: Option<u64>
) -> Result<String, Error>

fn delete_message(&self, qname: &str, msgid: &str) -> Result<bool, Error>

fn pop_message(&self, qname: &str) -> Result<Message, Error>

fn receive_message(
    &self,
    qname: &str,
    hidefor: Option<u64>
) -> Result<Message, Error>

fn get_queue_attributes(&self, qname: &str) -> Result<Queue, Error>

fn set_queue_attributes(
    &self,
    qname: &str,
    vt: Option<u64>,
    delay: Option<u64>,
    maxsize: Option<i64>
) -> Result<Queue, Error>

Trait Implementations

impl Debug for Rsmq

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

Formats the value using the given formatter.