RocketMQA2aConfig
public class RocketMQA2aConfig源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:21–399RocketMQ A 2 a 配置，保存相关配置项。位于 io.agentscope.extensions.rocketmq.a2a.config 包。核心成员包括 getRocketMQEndpoint、setRocketMQEndpoint、getRocketMQNamespace、setRocketMQNamespace、getBizTopic、setBizTopic。
Configuration class for RocketMQ A2A (Agent-to-Agent) communication.
嵌套类摘要Nested Class Summary
| 类Class | 类型Kind | 说明Description |
|---|---|---|
Builder | 类class | 构建器，用于构建并配置目标实例。 Builder class for constructing RocketMQA2aConfig instances. |
构造器摘要Constructor Summary
| 构造器Constructor | 说明Description |
|---|---|
public RocketMQA2aConfig(String rocketMQEndpoint, String rocketMQNamespace, String bizTopic, String bizConsumerGroup, String accessKey, String secretKey, String workAgentResponseTopic, String workAgentResponseGroupId) | 初始化 `RocketMQA2aConfig` 实例。 Constructs a RocketMQA2aConfig with all fields. |
public RocketMQA2aConfig() | 初始化 `RocketMQA2aConfig` 实例。 Default constructor. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public String getRocketMQEndpoint() | 获取RocketMQ 服务端点。 Gets the RocketMQ service endpoint. |
public void setRocketMQEndpoint(String rocketMQEndpoint) | 设置RocketMQ 服务端点。 Sets the RocketMQ service endpoint. |
public String getRocketMQNamespace() | 获取命名空间用于资源隔离。 Gets the namespace for resource isolation. |
public void setRocketMQNamespace(String rocketMQNamespace) | 设置命名空间用于资源隔离。 Sets the namespace for resource isolation. |
public String getBizTopic() | 获取 `getBizTopic`。 Gets the business topic for receiving requests. |
public void setBizTopic(String bizTopic) | 设置 `setBizTopic`。 Sets the business topic for receiving requests. |
public String getBizConsumerGroup() | 获取 `getBizConsumerGroup`。 Gets the consumer group for the business topic. |
public void setBizConsumerGroup(String bizConsumerGroup) | 设置 `setBizConsumerGroup`。 Sets the consumer group for the business topic. |
public String getAccessKey() | 获取访问键。 Gets the authentication access key. |
public void setAccessKey(String accessKey) | 设置访问键。 Sets the authentication access key. |
public String getSecretKey() | 获取密钥键。 Gets the authentication secret key. |
public void setSecretKey(String secretKey) | 设置密钥键。 Sets the authentication secret key. |
public String getWorkAgentResponseTopic() | 获取 `getWorkAgentResponseTopic`。 Gets the topic for receiving async responses. |
public void setWorkAgentResponseTopic(String workAgentResponseTopic) | 设置 `setWorkAgentResponseTopic`。 Sets the topic for receiving async responses. |
public String getWorkAgentResponseGroupId() | 获取消费者组用于响应主题。 Gets the consumer group for the response topic. |
public void setWorkAgentResponseGroupId(String workAgentResponseGroupId) | 设置消费者组用于响应主题。 Sets the consumer group for the response topic. |
public static Builder builder()static | 返回新的构建器实例。 Returns a new Builder instance. |
public String toString() | 返回 `toString` 结果。 Returns the to string. |
构造器详情Constructor Detail
RocketMQA2aConfig
public RocketMQA2aConfig(String rocketMQEndpoint, String rocketMQNamespace, String bizTopic, String bizConsumerGroup, String accessKey, String secretKey, String workAgentResponseTopic, String workAgentResponseGroupId)初始化 RocketMQA2aConfig 实例。
Constructs a RocketMQA2aConfig with all fields.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
rocketMQEndpoint | String | RocketMQ 服务端点。the RocketMQ service endpoint. |
rocketMQNamespace | String | 命名空间用于资源隔离。the namespace for resource isolation. |
bizTopic | String | biz 主题（类型 `String`）。the business topic for receiving requests. |
bizConsumerGroup | String | biz 消费者组（类型 `String`）。the consumer group for the business topic. |
accessKey | String | 访问键（类型 `String`）。the authentication access key. |
secretKey | String | 密钥键（类型 `String`）。the authentication secret key. |
workAgentResponseTopic | String | work 智能体响应主题（类型 `String`）。the topic for async responses. |
workAgentResponseGroupId | String | 消费者组用于响应主题。the consumer group for response topic. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:74–91RocketMQA2aConfig
public RocketMQA2aConfig()初始化 RocketMQA2aConfig 实例。
Default constructor.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:96方法详情Method Detail
getRocketMQEndpoint
public String getRocketMQEndpoint()获取RocketMQ 服务端点。
Gets the RocketMQ service endpoint.
String端点。the endpoint.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:103–105setRocketMQEndpoint
public void setRocketMQEndpoint(String rocketMQEndpoint)设置RocketMQ 服务端点。
Sets the RocketMQ service endpoint.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
rocketMQEndpoint | String | 端点到设置。the endpoint to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:112–114getRocketMQNamespace
public String getRocketMQNamespace()获取命名空间用于资源隔离。
Gets the namespace for resource isolation.
String命名空间。the namespace.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:121–123setRocketMQNamespace
public void setRocketMQNamespace(String rocketMQNamespace)设置命名空间用于资源隔离。
Sets the namespace for resource isolation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
rocketMQNamespace | String | 命名空间到设置。the namespace to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:130–132getBizTopic
public String getBizTopic()获取 getBizTopic。
Gets the business topic for receiving requests.
String返回字符串结果。the business topic.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:139–141setBizTopic
public void setBizTopic(String bizTopic)设置 setBizTopic。
Sets the business topic for receiving requests.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
bizTopic | String | 主题到设置。the topic to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:148–150getBizConsumerGroup
public String getBizConsumerGroup()获取 getBizConsumerGroup。
Gets the consumer group for the business topic.
String消费者组。the consumer group.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:157–159setBizConsumerGroup
public void setBizConsumerGroup(String bizConsumerGroup)设置 setBizConsumerGroup。
Sets the consumer group for the business topic.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
bizConsumerGroup | String | 消费者组到设置。the consumer group to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:166–168getAccessKey
public String getAccessKey()获取访问键。
Gets the authentication access key.
String访问密钥。the access key.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:175–177setAccessKey
public void setAccessKey(String accessKey)设置访问键。
Sets the authentication access key.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
accessKey | String | 访问密钥到设置。the access key to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:184–186getSecretKey
public String getSecretKey()获取密钥键。
Gets the authentication secret key.
String密钥密钥。the secret key.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:193–195setSecretKey
public void setSecretKey(String secretKey)设置密钥键。
Sets the authentication secret key.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
secretKey | String | 密钥密钥到设置。the secret key to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:202–204getWorkAgentResponseTopic
public String getWorkAgentResponseTopic()获取 getWorkAgentResponseTopic。
Gets the topic for receiving async responses.
String响应主题。the response topic.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:211–213setWorkAgentResponseTopic
public void setWorkAgentResponseTopic(String workAgentResponseTopic)设置 setWorkAgentResponseTopic。
Sets the topic for receiving async responses.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
workAgentResponseTopic | String | 主题到设置。the topic to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:220–222getWorkAgentResponseGroupId
public String getWorkAgentResponseGroupId()获取消费者组用于响应主题。
Gets the consumer group for the response topic.
String响应消费者组。the response consumer group.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:229–231setWorkAgentResponseGroupId
public void setWorkAgentResponseGroupId(String workAgentResponseGroupId)设置消费者组用于响应主题。
Sets the consumer group for the response topic.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
workAgentResponseGroupId | String | 消费者组到设置。the consumer group to set. |
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:238–240builder
public static Builder builder()static
返回新的构建器实例。
Returns a new Builder instance.
Builder构建器。the builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:247–249toString
public String toString()返回 toString 结果。
Returns the to string.
String返回字符串结果。Returns a string.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:370–398嵌套类详情Nested Class Detail
Builder
public static class Builder构建器，用于构建并配置目标实例。位于 io.agentscope.extensions.rocketmq.a2a.config 包。核心成员包括 rocketMQEndpoint、rocketMQNamespace、bizTopic、bizConsumerGroup、accessKey、secretKey。
Builder class for constructing RocketMQA2aConfig instances.