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

mikexue 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 eec78bdc4 [ISSUE #3208]Remove redundant log placeholders
     new c2ede5d30 Merge pull request #3209 from mxsm/eventmesh-3208
eec78bdc4 is described below

commit eec78bdc43cf3fb3035af5305d6819b4f3bd6a62
Author: mxsm <[email protected]>
AuthorDate: Mon Feb 20 00:03:28 2023 +0800

    [ISSUE #3208]Remove redundant log placeholders
---
 .../apache/eventmesh/client/grpc/consumer/SubStreamHandler.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
 
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
index 61e78258c..6026e6348 100644
--- 
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
+++ 
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
@@ -101,7 +101,7 @@ public class SubStreamHandler<T> extends Thread {
             @Override
             public void onError(final Throwable t) {
                 if (log.isErrorEnabled()) {
-                    log.error("Received Server side error :{}", t);
+                    log.error("Received Server side error", t);
                 }
                 close();
             }
@@ -141,7 +141,7 @@ public class SubStreamHandler<T> extends Thread {
         try {
             latch.await();
         } catch (InterruptedException e) {
-            log.error("SubStreamHandler Thread interrupted:{}", e);
+            log.error("SubStreamHandler Thread interrupted", e);
         }
     }
 
@@ -163,7 +163,7 @@ public class SubStreamHandler<T> extends Thread {
                 sender.onNext(subscription);
             }
         } catch (Exception e) {
-            log.error("StreamObserver Error onNext:{}", e);
+            log.error("StreamObserver Error onNext", e);
         }
     }
 
@@ -173,7 +173,7 @@ public class SubStreamHandler<T> extends Thread {
                 sender.onCompleted();
             }
         } catch (Exception e) {
-            log.error("StreamObserver Error onComplete:{}", e);
+            log.error("StreamObserver Error onComplete", e);
         }
     }
 }


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

Reply via email to