Struct CommandHandler 

pub struct CommandHandler { /* private fields */ }

Implementations

impl CommandHandler

pub fn parse_payload<T>(&self) -> Result<T, Error>

where T: for<'de> Deserialize<'de>,

pub fn get_payload(&self) -> &HashMap<String, Value>

pub async fn ack( &self, payload_for_next_step: Value, ) -> Result<(), RabbitMQError>

pub async fn nack_with_delay( &self, delay: Duration, max_retries: i32, ) -> Result<(i32, Duration), RabbitMQError>

pub async fn nack_with_fibonacci_strategy( &self, max_occurrence: i32, max_retries: i32, ) -> Result<(i32, Duration, i32), RabbitMQError>

Trait Implementations

impl Clone for CommandHandler

fn clone(&self) -> CommandHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.