Struct MessageBus 

pub struct MessageBus {
    agents: Mutex<HashMap<String, AgentConnection>>,
    offline_queues: Mutex<HashMap<String, VecDeque<BusMessage>>>,
}

Fields

agents: Mutex<HashMap<String, AgentConnection>>

offline_queues: Mutex<HashMap<String, VecDeque<BusMessage>>>

Implementations

impl MessageBus

pub fn new() -> Self

pub fn register( &self, agent_id: &str, connection_type: &str, ) -> UnboundedReceiver<BusMessage>

Register an agent on the bus with a WebSocket push channel. Returns a receiver for messages pushed to this agent.

pub fn register_http(&self, agent_id: &str)

Register an HTTP-polling agent (no WebSocket push channel). Messages sent to this agent are queued in the offline queue and retrieved via read_messages.

pub fn unregister(&self, agent_id: &str)

Unregister an agent from the bus.

pub fn touch(&self, agent_id: &str)

Update last_seen timestamp for an agent (called on HTTP polling).

pub fn send(&self, msg: BusMessage) -> Result<(), String>

Send a message to a specific agent.

pub fn inject( &self, from: &str, from_uid: &str, target: &str, message: &str, priority: Priority, ) -> Result<String, String>

Inject a message into an agent’s terminal (jekt). This is the same as send but with MessageType::Inject.

pub fn broadcast( &self, from: &str, from_uid: &str, payload: &str, priority: Priority, ) -> Result<usize, String>

Broadcast a message to all connected agents (except sender).

pub fn list_agents(&self) -> Vec<AgentInfo>

List all registered agents.

pub fn read_messages(&self, agent_id: &str, limit: usize) -> Vec<BusMessage>

Read (and drain) queued offline messages for an agent. Used by HTTP-polling agents that don’t have a WebSocket connection.

pub fn delete_messages(&self, agent_id: &str, message_ids: &[String]) -> usize

Delete specific messages by ID from an agent’s offline queue.

fn queue_offline(&self, msg: BusMessage)

fn drain_offline_queue(&self, agent_id: &str)