Struct LapinPublish 

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

The fire-and-forget publish policy: pure declaration, constructible anywhere.

OutgoingMessage::name is the routing key; the target exchange is a property of the policy (the default exchange unless exchange says otherwise). On the default exchange the routing key addresses the queue with that name. Messages are published persistent (delivery mode 2) unless persistent(false) opts out.

It pairs into LapinPublisher, and it is the broker’s DefaultPublish policy, so a publish("dest") handler mounted without an explicit publisher replies through it. confirms and server_tx move to the transactional policies, keeping the options.

Examples

use ruststream_lapin::LapinPublish;

let events = LapinPublish::default().exchange("events");
let shipments = LapinPublish::default().confirms();

Implementations

impl LapinPublish

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

Publishes to exchange instead of the default exchange.

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

Whether messages are marked persistent (delivery mode 2). Defaults to true.

pub fn confirms(self) -> ConfirmsPublish

Moves to the policy that awaits broker confirms, with buffering transactions.

The recommended transactional publisher: durable and much faster than AMQP server transactions.

pub fn server_tx(self) -> ServerTxPublish

Moves to the policy backed by AMQP server transactions (tx.select).

Server-side atomicity, at the cost of a synchronous commit round trip that is significantly slower than confirms.

Trait Implementations

impl Clone for LapinPublish

fn clone(&self) -> LapinPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LapinPublish

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

Formats the value using the given formatter.

impl Default for LapinPublish

fn default() -> LapinPublish

Returns the “default value” for a type.

impl Eq for LapinPublish

impl LapinPublishPolicy for LapinPublish

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

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

impl PartialEq for LapinPublish

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

Equality operator ==.

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

Inequality operator !=.

impl PublishPolicy<ConnectedLapinBroker> for LapinPublish

type Live = LapinPublisher

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).

async fn pair( self, connected: &ConnectedLapinBroker, ) -> Result<Self::Live, PairError>

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

impl StructuralPartialEq for LapinPublish