Struct rabbitmq_stream_client::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 Fn(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 Fn(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>

Trait Implementations

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.