Struct LapinTestBroker 

pub struct LapinTestBroker { /* private fields */ }

In-process broker for application tests: same descriptors, no RabbitMQ server.

Clones share one router, so a publisher and a subscriber cloned from the same broker see each other; separate new calls are fully isolated.

Examples

use ruststream::{Broker, Publisher, Subscriber, OutgoingMessage};
use ruststream_lapin::testing::LapinTestBroker;
let broker = LapinTestBroker::new();
let mut subscriber = broker.subscribe("orders").await?;
broker.publisher().publish(OutgoingMessage::new("orders", b"{}")).await?;

Implementations

impl LapinTestBroker

pub fn new() -> Self

Creates an isolated in-process broker.

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.

pub fn publisher(&self) -> LapinTestPublisher

A publisher into this broker’s router.

Trait Implementations

impl Broker for LapinTestBroker

type Error = AmqpError

The error type returned by broker-level operations.

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

Establishes the connection to the broker. Idempotent: calling multiple times must not open additional sockets.

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

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

impl Clone for LapinTestBroker

fn clone(&self) -> LapinTestBroker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LapinTestBroker

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

Formats the value using the given formatter.

impl Default for LapinTestBroker

fn default() -> LapinTestBroker

Returns the “default value” for a type.

impl DescribeServer for LapinTestBroker

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.

impl Subscribe for LapinTestBroker

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<LapinTestBroker> 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, broker: &LapinTestBroker, ) -> Result<Self::Subscriber, AmqpError>

Opens the subscription against broker. Called once, after Broker::connect.

impl TestableBroker for LapinTestBroker

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.