Struct ConnectedLapinTestBroker 

pub struct ConnectedLapinTestBroker { /* private fields */ }

The connected form of LapinTestBroker.

Routes published messages to subscribers by exact queue name (the default-exchange model) and implements TestableBroker, so it drives both the TestApp harness and the framework’s conformance suite in process. Clones share one router, so a publisher and a subscriber taken from the same broker see each other.

Implementations

impl ConnectedLapinTestBroker

pub async fn subscribe( &self, queue: impl Into<String>, ) -> Result<LapinTestSubscriber, AmqpError>

Subscribes to queue (exact-name routing, the default-exchange model).

Errors

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

pub fn publisher(&self, policy: LapinTestPublish) -> LapinTestPublisher

A live publisher into this broker’s router, mirroring ConnectedLapinBroker::publisher. The in-process transport routes by queue name only, so it has a single policy.

Trait Implementations

impl Clone for ConnectedLapinTestBroker

fn clone(&self) -> ConnectedLapinTestBroker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectedBroker for ConnectedLapinTestBroker

type Error = AmqpError

The error type returned by connected-broker operations.

type Closed = ()

The terminal witness returned by shutdown.

async fn shutdown(self) -> Result<Self::Closed, Self::Error>

Closes the broker connection, flushing in-flight publishes and stopping background tasks, consuming the connected form.

impl Debug for ConnectedLapinTestBroker

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedLapinTestBroker

type Policy = LapinTestPublish

The broker’s plain publish policy, constructible with its defaults.

impl PublishPolicy<ConnectedLapinTestBroker> for LapinTestPublish

type Live = LapinTestPublisher

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: &ConnectedLapinTestBroker, ) -> Result<Self::Live, PairError>

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

impl Subscribe for ConnectedLapinTestBroker

type Subscriber = LapinTestSubscriber

The subscriber type opened by a by-name subscription.

async fn subscribe(&self, name: &str) -> Result<Self::Subscriber, Self::Error>

Opens a subscription to name, producing this broker’s Subscriber.

impl SubscriptionSource<ConnectedLapinTestBroker> for RabbitQueue

Available on crate feature testing only.

type Subscriber = LapinTestSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, connected: &ConnectedLapinTestBroker, ) -> Result<Self::Subscriber, AmqpError>

Opens the subscription against the connected broker. Called once at startup.

impl TestableBroker for ConnectedLapinTestBroker

fn install_coordinator(&self, coordinator: Coordinator)

Installs the harness coordinator into this broker’s bus for a test run. Idempotent: a second install on the same broker is ignored.

fn inject(&self, message: OutgoingMessage<'_>)

Injects a message onto the bus as an external producer would, synchronously (no awaiting). Routes through the broker’s normal fanout, so it is recorded and counted like any publish.

fn published(&self, name: &str) -> Vec<RawMessage>

Returns every message published to name on this broker, in publish order. Backs the harness’s published::<T>(name) assertions and expect_published.