Struct AgentMessageBus 

pub struct AgentMessageBus { /* private fields */ }

A shared message bus for inter-agent communication within a swarm.

The message bus is shared across all workers in a swarm via Arc<RwLock<>>. Workers can send messages to specific roles or broadcast to all. Messages are retained for the lifetime of the swarm and can be queried.

Implementations

impl AgentMessageBus

pub fn new(max_messages: usize) -> Self

Create a new message bus with the given capacity.

pub fn send( &mut self, sender: &str, recipient: &str, msg_type: MessageType, content: &str, metadata: HashMap<String, String>, ) -> String

Send a message to a specific recipient (or “*” for broadcast).

pub fn messages_for(&self, role: &str) -> Vec<&AgentMessage>

Get all messages addressed to a specific role (or “*” for broadcast).

pub fn messages_from(&self, sender: &str) -> Vec<&AgentMessage>

Get all messages from a specific sender.

pub fn messages_of_type(&self, msg_type: &MessageType) -> Vec<&AgentMessage>

Get all messages of a specific type.

pub fn all_messages(&self) -> &[AgentMessage]

Get all messages in the bus.

pub fn len(&self) -> usize

Get the number of messages in the bus.

pub fn is_empty(&self) -> bool

Check if the bus is empty.

pub fn format_for_prompt(&self, role: &str, max_messages: usize) -> String

Format recent messages for inclusion in an LLM prompt.

Returns a string with the last N messages formatted for the agent’s context.

Trait Implementations

impl Clone for AgentMessageBus

fn clone(&self) -> AgentMessageBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AgentMessageBus

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

Formats the value using the given formatter.