ruststream-pulsar 0.6.0

Apache Pulsar broker implementation for the RustStream messaging framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! In-process test support, behind the `testing` feature.
//!
//! [`PulsarTestBroker`] is a handler-stub transport that reproduces the crate's core routing in
//! memory - no server, no network - and implements
//! [`TestableBroker`](ruststream::testing::TestableBroker) on its connected form, so
//! application handlers can be unit-tested with the
//! [`TestApp`](ruststream::testing::TestApp) harness. It routes by exact address match and does
//! not simulate broker-specific semantics (dead-letter policies, credit, redelivery timing);
//! those are verified end to end against a real broker.

mod broker;
mod router;
mod subscriber;

pub use broker::{
    ConnectedPulsarTestBroker, PulsarTestBroker, PulsarTestPublish, PulsarTestPublisher,
};
pub use subscriber::{PulsarTestMessage, PulsarTestSubscriber};