Struct LapinPublishOptions 

pub struct LapinPublishOptions {
    pub priority: Option<u8>,
    pub expiration: Option<Duration>,
    pub persistent: Option<bool>,
}

The AMQP basic properties one publish may differ from the next in.

Every field is optional because a publish carries only what its call site adjusted; the rest is what the publish policy fixed when it paired the publisher. The policy carries the defaults (LapinPublish::priority, expiration, persistent), the steps of LapinPublishSteps adjust one message, and the publisher resolves the two before it builds the frame.

A test reads the value back from the slot view: tb.out::<Alerts>().with_options(..) takes this type, which is why it derives Debug and PartialEq.

Examples

use ruststream::OutSlot;
use ruststream::testing::TestApp;
use ruststream_lapin::prelude::*;
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize, Deserialize, PartialEq, Outgoing)]
struct Alert {
    level: u8,
}

#[derive(OutSlot)]
#[publishes(Alert)]
struct Alerts;

#[subscriber("alerts.raw")]
async fn escalate(
    alert: &Alert,
    Out(alerts): Out<impl Publisher<Options = LapinPublishOptions>, Alerts>,
) -> HandlerOutcome {
    let sent = alerts.message(alert).to("alerts").priority(alert.level).publish().await;
    if sent.is_err() {
        return HandlerOutcome::retry();
    }
    HandlerOutcome::ack()
}

let app = RustStream::new(AppInfo::new("alerts", "0.1.0")).with_broker(
    LapinBroker::new("amqp://localhost:5672"),
    |b| {
        b.include(escalate).out(Alerts, Publish::default()).build();
    },
);
let tb = TestApp::start(app).await?;

tb.broker::<LapinBroker>()
    .message(&Alert { level: 9 })
    .to("alerts.raw")
    .publish()
    .await?;

tb.out::<Alerts>()
    .assert_called_once()
    .with_options(&LapinPublishOptions {
        priority: Some(9),
        ..LapinPublishOptions::default()
    });

Fields

priority: Option<u8>

The AMQP priority property (0..=255), or None to keep the policy’s.

expiration: Option<Duration>

The AMQP per-message expiration (TTL), or None to keep the policy’s. AMQP counts it in whole milliseconds; a shorter non-zero value becomes one millisecond.

persistent: Option<bool>

Whether the message is marked persistent (delivery mode 2), or None to keep the policy’s.

Trait Implementations

impl Clone for LapinPublishOptions

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 LapinPublishOptions

impl Debug for LapinPublishOptions

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

Formats the value using the given formatter.

impl Default for LapinPublishOptions

fn default() -> Self

Returns the “default value” for a type.

impl Eq for LapinPublishOptions

impl PartialEq for LapinPublishOptions

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LapinPublishOptions