Struct AmqpPublisher 

pub struct AmqpPublisher { /* private fields */ }

Publishes messages to AMQP addresses, one sender link per address, attached lazily on the shared publisher session.

Buildable before connect (it resolves the connection through the broker’s shared cell) and usable until shutdown; afterwards every publish reports AmqpError::NotConnected instead of silently succeeding against a dead connection.

Trait Implementations

impl Clone for AmqpPublisher

fn clone(&self) -> AmqpPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AmqpPublisher

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

Formats the value using the given formatter.

impl Publisher for AmqpPublisher

type Error = AmqpError

The error type returned by publish.

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

Publishes a message to the broker.

impl RequestReply for AmqpPublisher

type Reply = AmqpMessage

The reply message type.

async fn request( &self, msg: OutgoingMessage<'_>, timeout: Duration, ) -> Result<Self::Reply, Self::Error>

Publishes msg and awaits a single correlated reply, or fails after timeout.