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

jonyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/master by this push:
     new 2eea9f375 [ISSUE #2338] use logger instead of prints the stack trace 
(#2485)
2eea9f375 is described below

commit 2eea9f375663f83fa1f986a352c9221ac696ae13
Author: YuanXin Hu <[email protected]>
AuthorDate: Wed Dec 7 10:59:12 2022 +0800

    [ISSUE #2338] use logger instead of prints the stack trace (#2485)
    
    * fix #2338
    
    #2338
    
    * use LOGGER replace log
    
    #2338
---
 .../apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java  | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
 
b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
index 85eb0e0a7..02ce264b1 100644
--- 
a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
+++ 
b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
@@ -30,8 +30,13 @@ import java.util.Objects;
 import java.util.function.BiConsumer;
 import java.util.function.Function;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 public class CloudEventUtils {
 
+    private static final Logger LOGGER = 
LoggerFactory.getLogger(CloudEventUtils.class);
+
     public static SendResult convertSendResult(
         org.apache.rocketmq.client.producer.SendResult rmqResult) {
         SendResult sendResult = new SendResult();
@@ -120,6 +125,7 @@ public class CloudEventUtils {
 
             message.getProperties().forEach((k, v) -> 
MessageAccessor.putProperty(rmqMessageExt, k, v));
         } catch (Exception e) {
+            LOGGER.error("Error with msgConvertExt", e);
             e.printStackTrace();
         }
         return rmqMessageExt;


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to