(rocketmq-a2a) branch main updated: Optimize the code style (#3)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong 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 beec330  Optimize the code style (#3)
beec330 is described below

commit beec330701bf535689fb6ae90eadfc97d1b2126e
Author: Drizzle <464473...@qq.com>
AuthorDate: Mon Dec 8 10:59:10 2025 +0800

    Optimize the code style (#3)
    
    * update
    
    Change-Id: I2b5f6364699c1c9e07b6ad381b801c49ce641559
    
    * optimize the code
    
    Change-Id: If2495360c76970ac88387e59e3ac15a6237e2f3e
    
    * update
    
    Change-Id: Iceef7a1bd1d05bfa498694ba7c3a007bbfdf378e
    
    * update
    
    Change-Id: Id0b75d941f02387d7b05a96731ea936526bae012
    
    ---------
    
    Co-authored-by: drizzle.zk <drizzle...@alibaba-inc.com>
---
 .../java/org/apache/rocketmq/a2a/transport/RocketMQTransport.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/src/main/java/org/apache/rocketmq/a2a/transport/RocketMQTransport.java 
b/src/main/java/org/apache/rocketmq/a2a/transport/RocketMQTransport.java
index 4890886..027d63c 100644
--- a/src/main/java/org/apache/rocketmq/a2a/transport/RocketMQTransport.java
+++ b/src/main/java/org/apache/rocketmq/a2a/transport/RocketMQTransport.java
@@ -263,14 +263,14 @@ public class RocketMQTransport implements ClientTransport 
{
                 String liteTopic = 
(String)request.metadata().get(RocketMQA2AConstant.LITE_TOPIC);
                 if (null != litePushConsumer && 
!StringUtils.isEmpty(liteTopic)) {
                     litePushConsumer.subscribeLite(liteTopic);
-                    System.out.println("litePushConsumer subscribeLite 
liteTopic: " + liteTopic);
+                    log.info("litePushConsumer subscribeLite liteTopic: {}", 
liteTopic);
                     
LITE_TOPIC_USE_DEFAULT_RECOVER_MAP.computeIfAbsent(this.rocketMQInstanceID, k 
-> new HashMap<>()).put(liteTopic, this.useDefaultRecoverMode);
                 }
 
                 String closeLiteTopic = 
(String)request.metadata().get(RocketMQA2AConstant.CLOSE_LITE_TOPIC);
                 if (null != litePushConsumer && 
!StringUtils.isEmpty(closeLiteTopic)) {
                     litePushConsumer.unsubscribeLite(closeLiteTopic);
-                    System.out.println("litePushConsumer unsubscribeLite " + 
closeLiteTopic);
+                    log.info("litePushConsumer unsubscribeLite liteTopic: {}", 
closeLiteTopic);
                     
LITE_TOPIC_USE_DEFAULT_RECOVER_MAP.computeIfAbsent(this.rocketMQInstanceID, k 
-> new HashMap<>()).remove(closeLiteTopic);
                 }
             }
@@ -540,7 +540,9 @@ public class RocketMQTransport implements ClientTransport {
             try {
                 litePushConsumer.subscribeLite(contextId);
                 liteTopic = contextId;
-            } catch (ClientException e) {}
+            } catch (ClientException e) {
+
+            }
         }
         return liteTopic;
     }