Struct LapinRequester 

pub struct LapinRequester { /* private fields */ }

The live request/reply client over RabbitMQ direct reply-to.

request publishes to the routing key named by OutgoingMessage::name (on the default exchange unless the policy’s exchange says otherwise) with reply-to set to the direct reply-to pseudo-queue and a generated correlation-id; the responder replies by publishing to the reply-to it received, echoing the correlation-id.

Direct reply-to is at-most-once: replies live in channel state on one broker node, so a dropped requester channel loses in-flight replies. The per-request timeout is the recovery mechanism.

Obtained by pairing LapinRequest with a connected broker (ConnectedLapinBroker::requester). Clones share the reply consumer and the pending-request table; like every live handle it aliases the connection and reports AmqpError::Closed once the broker has shut down.

Trait Implementations

impl Clone for LapinRequester

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 LapinRequester

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

Formats the value using the given formatter.

impl Publisher for LapinRequester

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 on the requester channel without expecting a reply.

The AMQP basic properties are options resolved over the policy’s defaults.

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.

impl RequestReply for LapinRequester

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

Sends msg and awaits the correlated reply.

Errors

Returns AmqpError::RequestTimeout when no reply arrives within timeout, AmqpError::Closed once the broker has shut down, and AmqpError::Request / AmqpError::Publish on channel failures.

Cancel safety

Cancel safe for the caller’s state: dropping the future abandons the pending slot and a late reply is discarded. The request itself may still have been published.

type Reply = LapinMessage

The reply message type.