Struct RmqRpcClient 

pub struct RmqRpcClient { /* private fields */ }

Implementations

impl RmqRpcClient

pub async fn connect(url: &str) -> Result<Self, Error>

pub async fn declare_queue(&self, queue: &str) -> Result<&Self, Error>

pub async fn send_message( &self, routing_key: &str, payload: Vec<u8>, ) -> Result<Delivery, Error>

pub async fn send_message_without_reply( &self, routing_key: &str, payload: Vec<u8>, ) -> Result<(), Error>

Trait Implementations

impl Debug for RmqRpcClient

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

Formats the value using the given formatter.