Builder
public static class Builder源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:254–368构建器，用于构建并配置目标实例。位于 io.agentscope.extensions.rocketmq.a2a.config 包。核心成员包括 rocketMQEndpoint、rocketMQNamespace、bizTopic、bizConsumerGroup、accessKey、secretKey。
Builder class for constructing RocketMQA2aConfig instances.
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public Builder rocketMQEndpoint(String rocketMQEndpoint) | 设置RocketMQ 端点。 Sets the RocketMQ endpoint. |
public Builder rocketMQNamespace(String rocketMQNamespace) | 设置命名空间。 Sets the namespace. |
public Builder bizTopic(String bizTopic) | 设置该配置项。 Sets the business topic. |
public Builder bizConsumerGroup(String bizConsumerGroup) | 设置该配置项。 Sets the business consumer group. |
public Builder accessKey(String accessKey) | 设置访问密钥。 Sets the access key. |
public Builder secretKey(String secretKey) | 设置密钥密钥。 Sets the secret key. |
public Builder workAgentResponseTopic(String workAgentResponseTopic) | 设置响应主题。 Sets the response topic. |
public Builder workAgentResponseGroupId(String workAgentResponseGroupId) | 设置响应消费者组。 Sets the response consumer group. |
public RocketMQA2aConfig build() | 构建并返回最终实例。 Builds and returns the RocketMQA2aConfig instance. |
方法详情Method Detail
rocketMQEndpoint
public Builder rocketMQEndpoint(String rocketMQEndpoint)设置RocketMQ 端点。
Sets the RocketMQ endpoint.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
rocketMQEndpoint | String | 端点。the endpoint. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:270–273rocketMQNamespace
public Builder rocketMQNamespace(String rocketMQNamespace)设置命名空间。
Sets the namespace.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
rocketMQNamespace | String | 命名空间。the namespace. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:281–284bizTopic
public Builder bizTopic(String bizTopic)设置该配置项。
Sets the business topic.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
bizTopic | String | 主题。the topic. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:292–295bizConsumerGroup
public Builder bizConsumerGroup(String bizConsumerGroup)设置该配置项。
Sets the business consumer group.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
bizConsumerGroup | String | 消费者组。the consumer group. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:303–306accessKey
public Builder accessKey(String accessKey)设置访问密钥。
Sets the access key.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
accessKey | String | 访问密钥。the access key. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:314–317secretKey
public Builder secretKey(String secretKey)设置密钥密钥。
Sets the secret key.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
secretKey | String | 密钥密钥。the secret key. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:325–328workAgentResponseTopic
public Builder workAgentResponseTopic(String workAgentResponseTopic)设置响应主题。
Sets the response topic.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
workAgentResponseTopic | String | 响应主题。the response topic. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:336–339workAgentResponseGroupId
public Builder workAgentResponseGroupId(String workAgentResponseGroupId)设置响应消费者组。
Sets the response consumer group.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
workAgentResponseGroupId | String | 消费者组。the consumer group. |
Builder返回当前实例，以支持链式调用。this builder.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:347–350build
public RocketMQA2aConfig build()构建并返回最终实例。
Builds and returns the RocketMQA2aConfig instance.
RocketMQA2aConfig返回RocketMQA2aConfig。the constructed config.
源码Source
io/agentscope/extensions/rocketmq/a2a/config/RocketMQA2aConfig.java:357–367