Struct pulsar::producer::MultiTopicProducer

pub struct MultiTopicProducer<Exe: Executor> { /* private fields */ }

Wrapper structure that manges multiple producers at once, creating them as needed

use pulsar::{Pulsar, TokioExecutor};

let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await?;
let mut producer = pulsar.producer().with_name("name").build_multi_topic();
let send_1 = producer.send(topic, &message).await?;
let send_2 = producer.send(topic, &message).await?;
send_1.await?;
send_2.await?;

Implementations

impl<Exe: Executor> MultiTopicProducer<Exe>

pub fn options(&self) -> &ProducerOptions

producer options

pub fn topics(&self) -> Vec<String>

list topics currently handled by this producer

pub async fn close_producer<S: Into<String>>( &mut self, topic: S ) -> Result<(), Error>

stops the producer

pub async fn send<T: SerializeMessage + Sized, S: Into<String>>( &mut self, topic: S, message: T ) -> Result<SendFuture, Error>

👎Deprecated: instead use send_non_blocking

sends one message on a topic

pub async fn send_non_blocking<T: SerializeMessage + Sized, S: Into<String>>( &mut self, topic: S, message: T ) -> Result<SendFuture, Error>

sends one message on a topic

pub async fn send_all<'a, 'b, T, S, I>( &mut self, topic: S, messages: I ) -> Result<Vec<SendFuture>, Error>

where T: 'b + SerializeMessage + Sized, I: IntoIterator<Item = T>, S: Into<String>, 'b: 'a,

👎Deprecated: instead use send_all_non_blocking

sends a list of messages on a topic

pub async fn send_all_non_blocking<'a, 'b, T, S, I>( &mut self, topic: S, messages: I ) -> Result<Vec<SendFuture>, Error>

where T: 'b + SerializeMessage + Sized, I: IntoIterator<Item = T>, S: Into<String>, 'b: 'a,

sends a list of messages on a topic