Struct MessageBus 

pub struct MessageBus { /* private fields */ }

Message bus for inter-agent communication

Implementations

impl MessageBus

pub fn new() -> Self

Create a new message bus with bounded channels

Uses bounded channels to prevent memory exhaustion under load:

• Broadcast channel: 5000 messages (high capacity for burst traffic)
• All messages channel: 10000 messages (monitoring may fall behind)

pub fn register_agent(&self, agent_id: AgentId) -> Result<()>

Register an agent with bounded message channels

Each agent gets a bounded channel with DEFAULT_CHANNEL_CAPACITY to prevent any single slow agent from causing memory exhaustion.

pub fn unregister_agent(&self, agent_id: &AgentId) -> Result<()>

Unregister an agent

pub fn send_message( &self, _from: AgentId, to: AgentId, message: Message, ) -> Result<()>

Send a message to a specific agent (non-blocking)

Returns an error if the agent’s channel is full or the agent is not found. This prevents slow agents from blocking the sender.

pub fn broadcast(&self, _from: AgentId, message: BroadcastMessage) -> Result<()>

Broadcast a message to all agents (non-blocking)

Returns an error if the broadcast channel is full.

pub fn get_receiver(&self, agent_id: &AgentId) -> Option<Receiver<Message>>

Get receiver for an agent

pub fn subscribe_all(&self) -> Receiver<AgentMessage>

Subscribe to all messages (for monitoring)

pub async fn publish_to_agent( &self, agent_id: &AgentId, message: AgentMessage, ) -> Result<()>

Publish a message to a specific agent (non-blocking)

Returns an error if either the agent’s channel or the monitoring channel is full. This prevents slow consumers from causing memory exhaustion.

pub fn get_agent_receiver( &self, agent_id: &AgentId, ) -> Option<Receiver<AgentMessage>>

Get agent message receiver for a specific agent

Trait Implementations

impl Default for MessageBus

fn default() -> Self

Returns the “default value” for a type.