[rocketmq-clients] branch java_dev updated: WiP

[aaronai]

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

aaronai pushed a commit to branch java_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/java_dev by this push:
     new 69ee290  WiP
69ee290 is described below

commit 69ee290ff5c181ef1c71c5f26c92af373cde724d
Author: Aaron Ai <yangkun....@gmail.com>
AuthorDate: Wed Jul 13 16:29:54 2022 +0800

    WiP
---
 .../java/org/apache/rocketmq/client/java/impl/TelemetrySession.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/TelemetrySession.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/TelemetrySession.java
index d97f84c..2e4e8dd 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/TelemetrySession.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/TelemetrySession.java
@@ -130,7 +130,7 @@ public class TelemetrySession implements 
StreamObserver<TelemetryCommand> {
             this.requestObserver = clientManager.telemetry(endpoints, metadata,
                 Duration.ofNanos(Long.MAX_VALUE), this);
         } finally {
-            this.observerLock.readLock().unlock();
+            this.observerLock.writeLock().unlock();
         }
     }