Struct LapinTestPublisher 

pub struct LapinTestPublisher { /* private fields */ }

The live publisher into the in-process router.

Mirrors ConfirmsPublisher transaction semantics: publishes buffer between begin_transaction and commit, abort discards them, and a call with no open transaction errors. Clones share the transaction buffer. Like the real publishers it aliases the transport and may outlive it: after the broker shuts down every publish reports AmqpError::Closed.

Trait Implementations

impl Clone for LapinTestPublisher

fn clone(&self) -> LapinTestPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LapinTestPublisher

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

Formats the value using the given formatter.

impl OwnedTransactions for LapinTestPublisher

Owned transactions, mirroring ConfirmsPublisher: every call opens an independent buffer-owning LapinTestTransaction, so any number can be open at once and the publisher keeps routing directly meanwhile.

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

Opens a transaction owned by the returned value.

Errors

Never fails: opening allocates a buffer and never touches the router.

type Transaction = LapinTestTransaction

The buffer-owning transaction opened by transaction.

impl Publisher for LapinTestPublisher

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

Routes msg to subscribers of the queue named by msg.name().

Errors

Returns AmqpError::InvalidOptions when the routing key is empty and AmqpError::Closed once the transport has shut down.

type Error = AmqpError

The error type returned by publish.

impl TransactionalPublisher for LapinTestPublisher

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

Opens the buffering transaction.

Errors

Returns AmqpError::Transaction when a transaction is already open; the open transaction is left untouched.

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

Replays the buffered publishes in order.

Errors

Returns AmqpError::Transaction when no transaction is open and AmqpError::Closed once the transport has shut down.

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

Discards the buffered publishes.

Errors

Returns AmqpError::Transaction when no transaction is open.