Struct XClaimOptions

pub struct XClaimOptions { /* private fields */ }

Options for the xclaim command

Implementations

impl XClaimOptions

pub fn idle_time(self, idle_time_millis: u64) -> Self

Set the idle time (last time it was delivered) of the message.

pub fn time(self, unix_time_milliseconds: u64) -> Self

This is the same as idle_time but instead of a relative amount of milliseconds, it sets the idle time to a specific Unix time (in milliseconds).

pub fn retry_count(self, count: usize) -> Self

Set the retry counter to the specified value.

pub fn force(self) -> Self

Creates the pending message entry in the PEL even if certain specified IDs are not already in the PEL assigned to a different client.

pub fn just_id(self) -> Self

Return just an array of IDs of messages successfully claimed, without returning the actual message.

Trait Implementations

impl Default for XClaimOptions

fn default() -> XClaimOptions

Returns the “default value” for a type.

impl IntoArgs for XClaimOptions

fn into_args(self, args: CommandArgs) -> CommandArgs

fn num_args(&self) -> usize