Struct LapinPublisher 

pub struct LapinPublisher { /* private fields */ }

The live fire-and-forget publisher, on the connection’s shared publish channel. Cheap to clone.

Paired from LapinPublish, so it always has a connection. It aliases that connection, though, and may outlive it: after the broker shuts down every publish reports AmqpError::Closed instead of silently succeeding against a dead connection.

Trait Implementations

impl Clone for LapinPublisher

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 LapinPublisher

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

Formats the value using the given formatter.

impl Publisher for LapinPublisher

type Payload = Lend

basic_publish takes the payload as &[u8] and copies it into the frame it sends, so this publisher reads the bytes and keeps nothing.

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

Publishes msg without waiting for a broker confirm.

The AMQP basic properties are options resolved over the policy’s defaults; a call that adjusted nothing publishes with the policy’s own settings.

Errors

Returns AmqpError::Closed once the broker has shut down and AmqpError::Publish when the channel rejects the frame.

Cancel safety

Not cancel safe: dropping the future may leave the message published or not.

type Error = AmqpError

The error type returned by publish.

type Options = LapinPublishOptions

The broker’s per-message settings: a QoS, a priority, an ordering key, whatever this transport lets one message differ from the next in.

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

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