You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/07/29 08:10:03 UTC
[rocketmq] 02/02: doc: add logger when write telemetry failed
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit c0e375123a2c9d7138c074353440b5395a3223af
Author: kaiyi.lk <ka...@alibaba-inc.com>
AuthorDate: Fri Jul 29 14:22:25 2022 +0800
doc: add logger when write telemetry failed
---
.../org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
index 968635bae..810534bd2 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
@@ -214,7 +214,8 @@ public class GrpcClientChannel extends ProxyChannel {
}
try {
observer.onNext(command);
- } catch (StatusRuntimeException | IllegalStateException statusRuntimeException) {
+ } catch (StatusRuntimeException | IllegalStateException exception) {
+ log.warn("write telemetry failed. command:{}", command, exception);
this.clearClientObserver(observer);
}
}