Struct AgentMessageBus 

pub struct AgentMessageBus { /* private fields */ }

Agent Message Bus for inter-agent communication

Implementations

impl AgentMessageBus

pub fn new() -> Self

Create a new message bus with default settings

pub fn with_config(max_history_size: usize, max_queue_size: usize) -> Self

Create a new message bus with custom settings

pub fn subscribe(&mut self, agent_id: impl Into<String>, types: Vec<String>)

Subscribe an agent to receive messages

pub fn unsubscribe(&mut self, agent_id: &str)

Unsubscribe an agent

pub fn is_subscribed(&self, agent_id: &str) -> bool

Check if an agent is subscribed

pub fn get_subscription(&self, agent_id: &str) -> Option<&MessageSubscription>

Get subscription for an agent

pub fn send(&mut self, message: AgentMessage) -> MessageBusResult<()>

Send a message to a specific agent or broadcast

pub fn broadcast( &mut self, message_type: &str, payload: Value, sender: &str, ) -> MessageBusResult<()>

Broadcast a message to all subscribed agents

pub fn get_queue(&self, agent_id: &str) -> Vec<AgentMessage>

Get all messages in an agent’s queue (without removing)

pub fn dequeue(&mut self, agent_id: &str, count: usize) -> Vec<AgentMessage>

Dequeue messages from an agent’s queue (removes them)

pub fn dequeue_all(&mut self, agent_id: &str) -> Vec<AgentMessage>

Dequeue all messages from an agent’s queue

pub fn queue_size(&self, agent_id: &str) -> usize

Get the number of messages in an agent’s queue

pub fn has_messages(&self, agent_id: &str) -> bool

Check if an agent has pending messages

pub fn get_history(&self, limit: Option<usize>) -> Vec<AgentMessage>

Get message history

pub fn clear_history(&mut self)

Clear message history

pub fn get_subscribed_agents(&self) -> Vec<String>

Get all subscribed agent IDs

pub fn cleanup_expired(&mut self) -> usize

Remove expired messages from all queues

pub fn stats(&self) -> MessageBusStats

Get statistics about the message bus

pub fn prepare_request( &mut self, to: &str, message_type: &str, payload: Value, from: &str, timeout: Duration, ) -> MessageBusResult<(String, Receiver<Value>)>

Send a request message and wait for a response with timeout

This method sends a message to the target agent with requires_response set to true, and waits for a response within the specified timeout duration.

Arguments

• to - Target agent ID
• message_type - Type of the message
• payload - Message payload
• from - Sender agent ID
• timeout - Maximum time to wait for a response

Returns

• Ok(Value) - The response payload
• Err(MessageBusError::RequestTimeout) - If no response is received within timeout
• Err(MessageBusError::MessageExpired) - If the message expires before delivery

pub fn respond( &mut self, request: &AgentMessage, payload: Value, ) -> MessageBusResult<()>

Send a response to a request message

This method sends a response to a previously received request message. The response is delivered to the original requester.

Arguments

• request - The original request message
• payload - Response payload

Returns

• Ok(()) - If the response was sent successfully
• Err(MessageBusError::InvalidMessage) - If the request doesn’t require a response
• Err(MessageBusError::NoResponse) - If no pending request was found

pub fn is_request_pending(&self, request_id: &str) -> bool

Check if a request is still pending

pub fn pending_request_count(&self) -> usize

Get the number of pending requests

pub fn cancel_request(&mut self, request_id: &str) -> bool

Cancel a pending request

Removes the pending request without sending a response. Returns true if the request was found and cancelled.

pub fn cleanup_expired_requests(&mut self) -> usize

Cleanup expired pending requests

Removes all pending requests that have exceeded their timeout. Returns the number of expired requests removed.

pub fn get_response( &mut self, agent_id: &str, request_id: &str, ) -> Option<AgentMessage>

Get a response message from an agent’s queue by request ID

Searches the agent’s queue for a response to the specified request. Returns and removes the response message if found.

pub fn find_message_in_history(&self, message_id: &str) -> Option<&AgentMessage>

Find a message in history by ID

pub fn get_responses_from_history(&self, request_id: &str) -> Vec<&AgentMessage>

Get all response messages for a specific request from history

Trait Implementations

impl Debug for AgentMessageBus

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

Formats the value using the given formatter.

impl Default for AgentMessageBus

fn default() -> Self

Returns the “default value” for a type.