Struct Producer

pub struct Producer<T>(/* private fields */);

API for publising messages to RabbitMQ stream

Implementations

impl Producer<NoDedup>

pub async fn send_with_confirm( &self, message: Message, ) -> Result<ConfirmationStatus, ProducerPublishError>

pub async fn batch_send_with_confirm( &self, messages: Vec<Message>, ) -> Result<Vec<ConfirmationStatus>, ProducerPublishError>

pub async fn batch_send<Fut>( &self, messages: Vec<Message>, cb: impl Fn(Result<ConfirmationStatus, ProducerPublishError>) -> Fut + Send + Sync + 'static, ) -> Result<(), ProducerPublishError>

where Fut: Future<Output = ()> + Send + Sync + 'static,

pub async fn send<Fut>( &self, message: Message, cb: impl FnOnce(Result<ConfirmationStatus, ProducerPublishError>) -> Fut + Send + Sync + 'static, ) -> Result<(), ProducerPublishError>

where Fut: Future<Output = ()> + Send + Sync + 'static,

impl Producer<Dedup>

pub async fn send_with_confirm( &mut self, message: Message, ) -> Result<ConfirmationStatus, ProducerPublishError>

pub async fn batch_send_with_confirm( &mut self, messages: Vec<Message>, ) -> Result<Vec<ConfirmationStatus>, ProducerPublishError>

pub async fn batch_send<Fut>( &mut self, messages: Vec<Message>, cb: impl Fn(Result<ConfirmationStatus, ProducerPublishError>) -> Fut + Send + Sync + 'static, ) -> Result<(), ProducerPublishError>

where Fut: Future<Output = ()> + Send + Sync + 'static,

pub async fn send<Fut>( &mut self, message: Message, cb: impl FnOnce(Result<ConfirmationStatus, ProducerPublishError>) -> Fut + Send + Sync + 'static, ) -> Result<(), ProducerPublishError>

where Fut: Future<Output = ()> + Send + Sync + 'static,

impl<T> Producer<T>

pub fn is_closed(&self) -> bool

pub async fn close(self) -> Result<(), ProducerCloseError>

pub async fn set_on_closed(&self, on_closed: Box<dyn OnClosed + Send + Sync>)

Trait Implementations

impl<T: Clone> Clone for Producer<T>

fn clone(&self) -> Producer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.