RocketMQA2aServer
public class RocketMQA2aServer源码Source
io/agentscope/extensions/rocketmq/a2a/server/RocketMQA2aServer.java:66–531RocketMQ A 2 a 服务端，支持智能体之间的发现、委派与协作。位于 io.agentscope.extensions.rocketmq.a2a.server 包。核心成员包括 init、RocketMQA2aServer。
RocketMQ-based A2A (Agent-to-Agent) server implementation. Handles JSON-RPC requests via RocketMQ messaging and supports streaming responses.
构造器摘要Constructor Summary
| 构造器Constructor | 说明Description |
|---|---|
public RocketMQA2aServer(AgentScopeA2aServer agentScopeA2aServer, RocketMQA2aConfig rocketMQA2aConfig) | 初始化 `RocketMQA2aServer` 实例。 Constructs a RocketMQ A2A server with the given configuration. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public void init() | 初始化 `RocketMQA2aServer` 实例。 Initializes RocketMQ producers, consumers and the server lite topic. |
构造器详情Constructor Detail
RocketMQA2aServer
public RocketMQA2aServer(AgentScopeA2aServer agentScopeA2aServer, RocketMQA2aConfig rocketMQA2aConfig)初始化 RocketMQA2aServer 实例。
Constructs a RocketMQ A2A server with the given configuration.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
agentScopeA2aServer | AgentScopeA2aServer | 智能体范围 A 2 a 服务端（类型 `AgentScopeA2aServer`）。the underlying A2A server. |
rocketMQA2aConfig | RocketMQA2aConfig | RocketMQ 配置。the RocketMQ configuration. |
源码Source
io/agentscope/extensions/rocketmq/a2a/server/RocketMQA2aServer.java:163–178方法详情Method Detail
init
public void init()初始化 RocketMQA2aServer 实例。
Initializes RocketMQ producers, consumers and the server lite topic.
源码Source
io/agentscope/extensions/rocketmq/a2a/server/RocketMQA2aServer.java:183–222