Struct LapinTestPublisher 

pub struct LapinTestPublisher { /* private fields */ }

Publisher into the in-process router.

Mirrors ConfirmsPublisher transaction semantics: publishes buffer between begin_transaction and commit, and abort discards them. Clones share the transaction buffer.

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

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

Errors

Never fails.

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

Replays the buffered publishes in order; a no-op when no transaction is open.

Errors

Never fails.

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

Discards the buffered publishes; a no-op when no transaction is open.

Errors

Never fails.