Struct SimpleMessageBus 

pub struct SimpleMessageBus { /* private fields */ }

简单消息总线

Implementations

impl SimpleMessageBus

pub fn new() -> Self

创建新的消息总线

pub async fn register(&self, agent_id: &str, tx: Sender<AgentEvent>)

注册智能体

pub async fn subscribe(&self, agent_id: &str, topic: &str)

订阅主题

pub async fn send_to(&self, target_id: &str, event: AgentEvent) -> Result<()>

发送点对点消息

pub async fn broadcast(&self, event: AgentEvent) -> Result<()>

广播消息给所有智能体

pub async fn publish(&self, topic: &str, event: AgentEvent) -> Result<()>

发布到主题

Trait Implementations

impl Default for SimpleMessageBus

Available on non-crate feature dora only.

fn default() -> Self

Returns the “default value” for a type.