Struct PulsarPublisher 

pub struct PulsarPublisher { /* private fields */ }

Publishes messages to Pulsar topics, one producer per topic, created lazily and shared through the broker core (so shutdown can close them).

A partition-key header becomes the message’s partition key, which keyed routing and KeyShared subscriptions order by. Awaits the broker’s send receipt, so Ok means the broker stored the message. Buildable before connect and usable until shutdown; afterwards every publish reports PulsarError::NotConnected.

Trait Implementations

impl Clone for PulsarPublisher

fn clone(&self) -> PulsarPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulsarPublisher

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

Formats the value using the given formatter.

impl Publisher for PulsarPublisher

type Error = PulsarError

The error type returned by publish.

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Publishes a message to the broker.