Struct RsmqSync

pub struct RsmqSync { /* private fields */ }

Implementations

impl RsmqSync

pub async fn new(options: RsmqOptions) -> RsmqResult<RsmqSync>

Creates a new RSMQ instance, including its connection

Trait Implementations

impl Clone for RsmqSync

fn clone(&self) -> RsmqSync

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RsmqSync

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

Formats the value using the given formatter.

impl RsmqConnectionSync for RsmqSync

fn change_message_visibility( &mut self, qname: &str, message_id: &str, hidden: Duration, ) -> RsmqResult<()>

Change the hidden time of a already sent message.

fn create_queue( &mut self, qname: &str, hidden: Option<Duration>, delay: Option<Duration>, maxsize: Option<i32>, ) -> RsmqResult<()>

Creates a new queue. Attributes can be later modified with “set_queue_attributes” method

fn delete_message(&mut self, qname: &str, id: &str) -> RsmqResult<bool>

Deletes a message from the queue.

fn delete_queue(&mut self, qname: &str) -> RsmqResult<()>

Deletes the queue and all messages in it

fn get_queue_attributes( &mut self, qname: &str, ) -> RsmqResult<RsmqQueueAttributes>

Returns the queue attributes and statistics

fn list_queues(&mut self) -> RsmqResult<Vec<String>>

Returns a list of queues in the namespace

fn pop_message<E: TryFrom<RedisBytes, Error = Vec<u8>>>( &mut self, qname: &str, ) -> RsmqResult<Option<RsmqMessage<E>>>

Deletes and returns a message. Be aware that using this you may end with deleted & unprocessed messages.

fn receive_message<E: TryFrom<RedisBytes, Error = Vec<u8>>>( &mut self, qname: &str, hidden: Option<Duration>, ) -> RsmqResult<Option<RsmqMessage<E>>>

Returns a message. The message stays hidden for some time (defined by “hidden” argument or the queue settings). After that time, the message will be redelivered. To avoid redelivery, use “delete_message” after this function.

fn send_message<E: Into<RedisBytes> + Send>( &mut self, qname: &str, message: E, delay: Option<Duration>, ) -> RsmqResult<String>

Sends a message to the queue. The message will be delayed some time (controlled by the “delayed” argument or the queue settings) before being delivered to a client.

fn set_queue_attributes( &mut self, qname: &str, hidden: Option<Duration>, delay: Option<Duration>, maxsize: Option<i64>, ) -> RsmqResult<RsmqQueueAttributes>

Modify the queue attributes. Note that “hidden” and “delay” can be overwritten when sending messages. “hidden” can be changed by the method “change_message_visibility”