Struct ServerTxPublish 

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

The server-transactional publish policy: same options as LapinPublish, pairing into ServerTxPublisher.

Reached with LapinPublish::server_tx.

Examples

use ruststream_lapin::LapinPublish;

let ledger = LapinPublish::default().exchange("ledger").server_tx();

Implementations

impl ServerTxPublish

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 ServerTxPublish

fn clone(&self) -> ServerTxPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerTxPublish

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

Formats the value using the given formatter.

impl Default for ServerTxPublish

fn default() -> ServerTxPublish

Returns the “default value” for a type.

impl Eq for ServerTxPublish

impl LapinPublishPolicy for ServerTxPublish

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

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

impl PartialEq for ServerTxPublish

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

Equality operator ==.

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

Inequality operator !=.

impl PublishPolicy<ConnectedLapinBroker> for ServerTxPublish

type Live = ServerTxPublisher

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 ServerTxPublish