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

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

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

Publishes msg without waiting for a broker confirm.

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.