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.

Reply via email to