Struct DirectReplyTo 

pub struct DirectReplyTo;

Redirects each reply of a #[subscriber(.., reply(..))] 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. A request without a reply-to header falls through to the mount site’s reply("..") name.

The transform names the destination per delivery, so it mounts only where nothing has declared one: the reply type derives Outgoing without #[outgoing(name = "..")] and the mount site supplies the fallback name. A reply type that declares its own destination refuses this transform at the mount site, which is what keeps the generated AsyncAPI document and the wire in step.

It writes none of the per-message AMQP properties, so it is generic over the publisher’s options and mounts over any of this crate’s publishers. The reply-to address and the correlation id it echoes are protocol fields the crate carries as headers, and the publisher puts them back on the frame.

Examples

use ruststream_lapin::prelude::*;
use serde::{Deserialize, Serialize};

#[derive(Deserialize)]
struct Ask {
    sku: String,
}

// An RPC reply goes wherever the request asked, so the destination belongs to the mount
// site and the type declares none.
#[derive(Serialize, Outgoing)]
struct Stock {
    available: bool,
}

#[subscriber("inventory.check", reply("inventory.check.unrouted"))]
async fn check(ask: &Ask) -> Stock {
    Stock {
        available: !ask.sku.is_empty(),
    }
}

fn app() -> RustStream {
    let broker = LapinBroker::new("amqp://localhost:5672");
    RustStream::new(AppInfo::new("inventory", "0.1.0")).with_broker(broker, |b| {
        b.include(check)
            .out_reply(Publish::default())
            .transform(DirectReplyTo);
    })
}

Trait Implementations

impl Clone for DirectReplyTo

fn clone(&self) -> Self

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() -> Self

Returns the “default value” for a type.

impl Eq for DirectReplyTo

impl PartialEq for DirectReplyTo

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

Equality operator ==.

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

Inequality operator !=.

impl<C, Options> PublishTransform<ForReply<C>, Options> for DirectReplyTo

type Destination = Names

What this transform does to the destination: Reads or Names.

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

Transforms out in place before it is sent, reading the position’s view through cx and resolving the broker’s per-message settings through options.

impl StructuralPartialEq for DirectReplyTo