Struct LapinRequest 

pub struct LapinRequest(/* private fields */);

The request/reply policy: pure declaration, constructible anywhere, pairing into LapinRequester.

Requests are published transient (delivery mode 1) by default: a request nobody is waiting for after the timeout gains nothing from surviving a broker restart. Opt into persistence with persistent(true).

Examples

use std::time::Duration;

use ruststream::OutgoingMessage;
use ruststream_lapin::prelude::*;
use serde::Deserialize;

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

#[subscriber("orders")]
async fn place(order: &Order, Out(inventory): Out<impl RequestReply>) -> HandlerOutcome {
    let ask = OutgoingMessage::new("inventory.check", order.sku.as_bytes());
    match inventory.request(ask, Duration::from_secs(2)).await {
        Ok(reply) if reply.payload() == b"in-stock" => HandlerOutcome::ack(),
        Ok(_) => HandlerOutcome::drop(),
        Err(_) => HandlerOutcome::retry(),
    }
}

fn app() -> RustStream {
    let broker = LapinBroker::new("amqp://localhost:5672");
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(broker, |b| {
        b.include(place)
            .out(DefaultSlot, LapinRequest::default().exchange("rpc"))
            .build();
    })
}

Implementations

impl LapinRequest

pub fn exchange(self, exchange: impl Into<String>) -> Self

Publishes requests to exchange instead of the default exchange.

pub fn persistent(self, persistent: bool) -> Self

Whether requests are marked persistent (delivery mode 2). Defaults to false.

One request departs from this with the publish builder’s persistent step.

pub fn priority(self, priority: u8) -> Self

The AMQP priority property requests carry. Unset by default.

One request departs from this with the publish builder’s priority step.

pub fn expiration(self, ttl: Duration) -> Self

The AMQP per-message expiration (TTL) requests carry: the broker drops one once ttl has passed without it being consumed. Unset by default.

Pair it with the per-request timeout: a request that expires on the broker fails with AmqpError::RequestTimeout at the caller, without a responder ever seeing it.

One request departs from this with the publish builder’s expiration step.

Trait Implementations

impl Clone for LapinRequest

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 LapinRequest

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

Formats the value using the given formatter.

impl Default for LapinRequest

fn default() -> Self

Returns the “default value” for a type.

impl Eq for LapinRequest

impl LapinPublishPolicy for LapinRequest

fn bind(self, connected: &ConnectedLapinBroker) -> Self::Live

Pairs the policy with the connected broker, producing the live publisher.

impl PartialEq for LapinRequest

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

Equality operator ==.

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

Inequality operator !=.

impl PublishPolicy<ConnectedLapinBroker> for LapinRequest

type Live = LapinRequester

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

fn pair( self, connected: &ConnectedLapinBroker, ) -> impl Future<Output = Result<Self::Live, PairError>>

Pairs the policy with a connected broker, producing the live publisher.

fn channel_bindings(&self, destination: &str) -> Bindings

What a publish through this policy adds to its channel in the generated AsyncAPI document.

fn operation_bindings(&self, _destination: &str) -> Bindings

What a publish through this policy adds to its send operation in the document.

fn reply_address_location(&self) -> Option<&'static str>

Where a client finds the address of a reply this policy publishes, as a runtime expression.

fn message_bindings(&self, channel: &str) -> Bindings

What a publish through this policy adds to the messages that leave through it.

impl StructuralPartialEq for LapinRequest