Struct ServerTxPublisher 

pub struct ServerTxPublisher { /* private fields */ }

The live publisher backed by AMQP server transactions (tx.select / tx.commit / tx.rollback).

Between begin_transaction and commit messages accumulate on the broker inside the channel transaction and become visible atomically at commit; abort rolls them back server-side. Outside a transaction publish behaves like the fire-and-forget publisher.

Only the borrowed transaction kind (TransactionalPublisher) applies here, unlike ConfirmsPublisher: tx.select puts the channel itself into transactional mode, so the transaction is channel state with exactly one instance, and there is no buffer for an owned Transaction value to own.

Clones share the transactional channel and its open/closed state. Interleaving publish and begin_transaction/commit from concurrent tasks is not supported: which side of the transaction boundary a concurrent publish lands on would be a race either way. Like every live publisher it aliases the connection and may outlive it: after shutdown every operation reports AmqpError::Closed.

Trait Implementations

impl Clone for ServerTxPublisher

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 ServerTxPublisher

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

Formats the value using the given formatter.

impl Publisher for ServerTxPublisher

type Payload = Lend

basic_publish takes the payload as &[u8] and copies it into the frame it sends, so this publisher reads the bytes and keeps nothing.

async fn publish( &self, msg: OutgoingMessage<'_>, options: Option<&Self::Options>, ) -> Result<(), Self::Error>

Publishes msg: into the open server transaction, or plainly when none is open.

The AMQP basic properties are options resolved over the policy’s defaults, either way.

Errors

Returns AmqpError::Closed once the broker has shut down and AmqpError::Publish when the channel rejects the frame.

Cancel safety

Not cancel safe: dropping the future may leave the message queued in the transaction or not.

type Error = AmqpError

The error type returned by publish.

type Options = LapinPublishOptions

The broker’s per-message settings: a QoS, a priority, an ordering key, whatever this transport lets one message differ from the next in.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.

impl TransactionalPublisher for ServerTxPublisher

async fn begin_transaction(&self) -> Result<(), Self::Error>

Opens a server transaction (tx.select on first use).

Errors

Returns AmqpError::Transaction when a transaction is already open on this handle (the open transaction is left untouched), AmqpError::Closed once the broker has shut down, and AmqpError::Publish when the transactional channel cannot be set up.

async fn commit(&self) -> Result<(), Self::Error>

Commits the open server transaction.

Errors

Returns AmqpError::Transaction when no transaction is open, and AmqpError::Publish when tx.commit fails; the transaction state on the broker is then unknown (the channel may be closed) and the publisher should be discarded.

async fn abort(&self) -> Result<(), Self::Error>

Rolls back the open server transaction.

Errors

Returns AmqpError::Transaction when no transaction is open, and AmqpError::Publish when tx.rollback fails.