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

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

Register an agent

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

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

Broadcast a message to all agents

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

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.