Struct pulsar::producer::Producer

pub struct Producer<Exe: Executor> { /* fields omitted */ }

Implementations

impl<Exe: Executor> Producer<Exe>

pub fn builder(pulsar: &Pulsar<Exe>) -> ProducerBuilder<Exe>

pub fn topic(&self) -> &str

pub fn partitions(&self) -> Option<Vec<String>>

pub fn options(&self) -> &ProducerOptions

pub fn create_message(&mut self) -> MessageBuilder<(), Exe>

pub async fn check_connection<'_>(&'_ self) -> Result<(), Error>

pub async fn send<T: SerializeMessage + Sized, '_>(
    &'_ mut self,
    message: T
) -> Result<SendFuture, Error>

Sends a message

this function returns a SendFuture because the receipt can come long after this function was called, for various reasons:

• the message was sent successfully but Pulsar did not send the receipt yet
• the producer is batching messages, so this function must return immediately, and the receipt will come when the batched messages are actually sent

Usage:

let f1 = producer.send("hello").await?;
let f2 = producer.send("world").await?;
let receipt1 = f1.await?;
let receipt2 = f2.await?;

pub async fn send_all<T, I, '_>(
    &'_ mut self,
    messages: I
) -> Result<Vec<SendFuture>, Error> where
    T: SerializeMessage,
    I: IntoIterator<Item = T>, 

pub async fn send_batch<'_>(&'_ mut self) -> Result<(), Error>

sends the current batch of messages