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).

The partition key travels per message: PulsarPublishSteps::partition_key names it at the call site, and a partition-key header names the same key for a caller that writes its headers itself. Awaits the broker’s send receipt, so Ok means the broker stored the message. A payload over the broker’s max_message_size fails with PulsarError::Publish without being sent. Buildable before connect and usable until shutdown; afterwards every publish reports PulsarError::NotConnected.

Trait Implementations

impl Clone for PulsarPublisher

fn clone(&self) -> Self

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 Options = PulsarPublishOptions

The partition key, the one value Pulsar lets one publish differ from the next in on this crate’s surface.

type Payload = Take

How this transport consumes the payload: Lend where it reads the bytes and keeps nothing, Take where its client keeps them.

type Error = PulsarError

The error type returned by publish.

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

Publishes a message to the broker, with the per-message settings the call site adjusted.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.