Struct ConfirmsPublish 

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

The confirm-transactional publish policy: same options as LapinPublish, pairing into ConfirmsPublisher.

Reached with LapinPublish::confirms.

Examples

use ruststream_lapin::LapinPublish;

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

Implementations

impl ConfirmsPublish

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.

Trait Implementations

impl Clone for ConfirmsPublish

fn clone(&self) -> ConfirmsPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConfirmsPublish

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

Formats the value using the given formatter.

impl Default for ConfirmsPublish

fn default() -> ConfirmsPublish

Returns the “default value” for a type.

impl Eq for ConfirmsPublish

impl LapinPublishPolicy for ConfirmsPublish

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

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

impl PartialEq for ConfirmsPublish

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

Equality operator ==.

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

Inequality operator !=.

impl PublishPolicy<ConnectedLapinBroker> for ConfirmsPublish

type Live = ConfirmsPublisher

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 ConfirmsPublish