Struct DirectReplyTo 

pub struct DirectReplyTo;

Redirects each reply of a #[subscriber(.., publish(..))] handler to the requester’s private reply-to address, echoing its correlation id.

This is the canonical responder wiring for request/reply over RabbitMQ direct reply-to: compose it onto the reply publisher at mount time and the handler stays a pure request-to-reply function. Requests without a reply-to header fall through to the mount’s static destination.

Examples

use ruststream::runtime::TypedPublisher;
use ruststream_lapin::{DirectReplyTo, LapinBroker};

let broker = LapinBroker::new("amqp://localhost:5672");
let replies = TypedPublisher::new(broker.publisher()).transform(DirectReplyTo);

Trait Implementations

impl Clone for DirectReplyTo

fn clone(&self) -> DirectReplyTo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DirectReplyTo

impl Debug for DirectReplyTo

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

Formats the value using the given formatter.

impl Default for DirectReplyTo

fn default() -> DirectReplyTo

Returns the “default value” for a type.

impl Eq for DirectReplyTo

impl PartialEq for DirectReplyTo

fn eq(&self, other: &DirectReplyTo) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<C> PublishTransform<C> for DirectReplyTo

fn apply(&self, out: &mut Outgoing<'_>, cx: &PublishContext<'_, C>)

Transforms out in place before it is sent, reading the delivery through cx.

impl StructuralPartialEq for DirectReplyTo