Struct ServerTxPublisher 

pub struct ServerTxPublisher { /* private fields */ }

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

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.

Trait Implementations

impl Clone for ServerTxPublisher

fn clone(&self) -> ServerTxPublisher

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

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

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

Errors

Returns AmqpError::NotConnected before Broker::connect resolves the connection 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.

impl TransactionalPublisher for ServerTxPublisher

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

Opens a server transaction (tx.select on first use); a no-op when one is open.

Errors

Returns AmqpError::NotConnected before Broker::connect resolves the connection and AmqpError::Publish when the transactional channel cannot be set up.

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

Commits the open server transaction; a no-op when none is open.

Errors

Returns 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; a no-op when none is open.

Errors

Returns AmqpError::Publish when tx.rollback fails.