Struct LapinTestBroker 

pub struct LapinTestBroker { /* private fields */ }

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

Mirrors the real ladder: new is synchronous, and the consuming connect hands out the ConnectedLapinTestBroker that carries the subscribe and publish surface.

Examples

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

Implementations

impl LapinTestBroker

pub fn new() -> Self

Creates an isolated in-process broker.

Trait Implementations

impl Broker for LapinTestBroker

type Error = AmqpError

The error type returned by broker-level operations.

type Connected = ConnectedLapinTestBroker

The connected form of this broker: the typed witness that connect succeeded.

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

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

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.