This is an automated email from the ASF dual-hosted git repository.
RongtongJin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-a2a.git
The following commit(s) were added to refs/heads/main by this push:
new 767e62b Fix typo in package name: uitl -> util (#31)
767e62b is described below
commit 767e62bb9c88347bc5ea44ee7bad2fc7429fcace
Author: KaiQuan Chen <[email protected]>
AuthorDate: Thu Jun 18 16:00:18 2026 +0800
Fix typo in package name: uitl -> util (#31)
Rename directory common/uitl/ to common/util/ and update all
package declarations and import statements.
---
.../src/main/java/agent/AgentCardProducer.java | 2 +-
.../src/main/java/agent/AgentCardProducer.java | 2 +-
.../common/{uitl => util}/RequestIdGenerator.java | 2 +-
.../a2a/common/{uitl => util}/RocketMQUtil.java | 2 +-
.../rocketmq/a2a/server/RocketMQA2AServerRoutes.java | 10 +++++-----
.../a2a/transport/impl/RocketMQTransport.java | 20 ++++++++++----------
6 files changed, 19 insertions(+), 19 deletions(-)
diff --git
a/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentCardProducer.java
b/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentCardProducer.java
index 14070b2..677405f 100644
---
a/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentCardProducer.java
+++
b/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentCardProducer.java
@@ -25,7 +25,7 @@ import io.a2a.spec.AgentSkill;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Produces;
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.ROCKETMQ_PROTOCOL;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.formatRocketMQServiceUrl;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.formatRocketMQServiceUrl;
/**
* Producer for the public {@link AgentCard} that describes this service's
capabilities.
diff --git
a/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentCardProducer.java
b/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentCardProducer.java
index 67eaa36..3796ffe 100644
---
a/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentCardProducer.java
+++
b/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentCardProducer.java
@@ -25,7 +25,7 @@ import io.a2a.spec.AgentSkill;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Produces;
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.ROCKETMQ_PROTOCOL;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.formatRocketMQServiceUrl;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.formatRocketMQServiceUrl;
/**
* Producer for the public {@link AgentCard} that describes this service's
capabilities.
diff --git
a/src/main/java/org/apache/rocketmq/a2a/common/uitl/RequestIdGenerator.java
b/src/main/java/org/apache/rocketmq/a2a/common/util/RequestIdGenerator.java
similarity index 98%
rename from
src/main/java/org/apache/rocketmq/a2a/common/uitl/RequestIdGenerator.java
rename to
src/main/java/org/apache/rocketmq/a2a/common/util/RequestIdGenerator.java
index 2c7f919..29e4fec 100644
--- a/src/main/java/org/apache/rocketmq/a2a/common/uitl/RequestIdGenerator.java
+++ b/src/main/java/org/apache/rocketmq/a2a/common/util/RequestIdGenerator.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.rocketmq.a2a.common.uitl;
+package org.apache.rocketmq.a2a.common.util;
import java.util.concurrent.ThreadLocalRandom;
diff --git
a/src/main/java/org/apache/rocketmq/a2a/common/uitl/RocketMQUtil.java
b/src/main/java/org/apache/rocketmq/a2a/common/util/RocketMQUtil.java
similarity index 99%
rename from src/main/java/org/apache/rocketmq/a2a/common/uitl/RocketMQUtil.java
rename to src/main/java/org/apache/rocketmq/a2a/common/util/RocketMQUtil.java
index 6aa6626..065ef9d 100644
--- a/src/main/java/org/apache/rocketmq/a2a/common/uitl/RocketMQUtil.java
+++ b/src/main/java/org/apache/rocketmq/a2a/common/util/RocketMQUtil.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.rocketmq.a2a.common.uitl;
+package org.apache.rocketmq.a2a.common.util;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
diff --git
a/src/main/java/org/apache/rocketmq/a2a/server/RocketMQA2AServerRoutes.java
b/src/main/java/org/apache/rocketmq/a2a/server/RocketMQA2AServerRoutes.java
index b0d5ba2..d25e220 100644
--- a/src/main/java/org/apache/rocketmq/a2a/server/RocketMQA2AServerRoutes.java
+++ b/src/main/java/org/apache/rocketmq/a2a/server/RocketMQA2AServerRoutes.java
@@ -87,11 +87,11 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import static io.a2a.util.Utils.OBJECT_MAPPER;
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.METHOD;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.buildLitePushConsumer;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.buildMessageForResponse;
-import static org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.buildProducer;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.buildPushConsumer;
-import static org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.toJsonString;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.buildLitePushConsumer;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.buildMessageForResponse;
+import static org.apache.rocketmq.a2a.common.util.RocketMQUtil.buildProducer;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.buildPushConsumer;
+import static org.apache.rocketmq.a2a.common.util.RocketMQUtil.toJsonString;
/**
* An A2A-protocol-compliant service router implemented on top of RocketMQ.
diff --git
a/src/main/java/org/apache/rocketmq/a2a/transport/impl/RocketMQTransport.java
b/src/main/java/org/apache/rocketmq/a2a/transport/impl/RocketMQTransport.java
index 90abc1c..87ccba6 100644
---
a/src/main/java/org/apache/rocketmq/a2a/transport/impl/RocketMQTransport.java
+++
b/src/main/java/org/apache/rocketmq/a2a/transport/impl/RocketMQTransport.java
@@ -79,16 +79,16 @@ import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.GET_TA
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.LIST_TASK_PUSH_NOTIFICATION_CONFIG_RESPONSE_REFERENCE;
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.SEND_MESSAGE_RESPONSE_REFERENCE;
import static
org.apache.rocketmq.a2a.common.constant.RocketMQA2AConstant.SET_TASK_PUSH_NOTIFICATION_CONFIG_RESPONSE_REFERENCE;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.LITE_TOPIC_USE_DEFAULT_RECOVER_MAP;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.MESSAGE_STREAM_RESPONSE_MAP;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.RECOVER_MESSAGE_STREAM_RESPONSE_MAP;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.checkConfigParam;
-import static org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.getResult;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.getOrCreateLitePushConsumer;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.getOrCreateProducer;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.parseAgentCardAddition;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.sendRocketMQRequest;
-import static
org.apache.rocketmq.a2a.common.uitl.RocketMQUtil.unmarshalResponse;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.LITE_TOPIC_USE_DEFAULT_RECOVER_MAP;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.MESSAGE_STREAM_RESPONSE_MAP;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.RECOVER_MESSAGE_STREAM_RESPONSE_MAP;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.checkConfigParam;
+import static org.apache.rocketmq.a2a.common.util.RocketMQUtil.getResult;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.getOrCreateLitePushConsumer;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.getOrCreateProducer;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.parseAgentCardAddition;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.sendRocketMQRequest;
+import static
org.apache.rocketmq.a2a.common.util.RocketMQUtil.unmarshalResponse;
/**
* A RocketMQ-based implementation of the {@link ClientTransport} interface
for A2A protocol communication.