Struct MessageBus 

pub struct MessageBus { /* private fields */ }

An in-process publish/subscribe message bus.

Supports topic-based subscriptions where subscribers can listen for specific message types. Messages published to the bus are stored in per-subscriber mailboxes for retrieval.

Implementations

impl MessageBus

pub fn new() -> Self

Creates a new message bus.

pub fn with_mailbox_size(max_size: usize) -> Self

Creates a new message bus with a custom mailbox size limit.

pub fn subscribe( &mut self, subscriber_id: Uuid, types: Vec<MessageType>, ) -> SubscriptionId

Subscribes to specific message types.

Returns a SubscriptionId that can be used to receive messages or unsubscribe later.

pub fn unsubscribe(&mut self, sub_id: &SubscriptionId) -> bool

Unsubscribes and removes the subscription.

pub fn publish(&mut self, message: BusMessage) -> usize

Publishes a message to all matching subscribers.

Returns the number of subscribers the message was delivered to.

pub fn receive(&mut self, sub_id: &SubscriptionId) -> Vec<BusMessage>

Receives all pending messages for a subscription.

Drains the mailbox, returning all messages.

pub fn pending_count(&self, sub_id: &SubscriptionId) -> usize

Returns the number of pending messages for a subscription.

pub fn subscription_count(&self) -> usize

Returns the total number of active subscriptions.

pub fn stats(&self) -> &BusStats

Returns bus statistics.

pub fn clear_mailboxes(&mut self)

Clears all mailboxes without removing subscriptions.

Trait Implementations

impl Debug for MessageBus

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

Formats the value using the given formatter.

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.