[incubator-dubbo] branch master updated: [Dubbo-4115] When the network is reconnected, the listener should not to be empty. (#4116)

[huxing]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 779fc27  [Dubbo-4115] When the network is reconnected, the listener 
should not to be empty. (#4116)
779fc27 is described below

commit 779fc27255b30c07164b2db6978c71e7fea0b82f
Author: yì jí <y...@apache.org>
AuthorDate: Thu May 23 17:40:30 2019 +0800

    [Dubbo-4115] When the network is reconnected, the listener should not to be 
empty. (#4116)
---
 .../java/org/apache/dubbo/remoting/etcd/jetcd/JEtcdClient.java   | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/dubbo-remoting/dubbo-remoting-etcd3/src/main/java/org/apache/dubbo/remoting/etcd/jetcd/JEtcdClient.java
 
b/dubbo-remoting/dubbo-remoting-etcd3/src/main/java/org/apache/dubbo/remoting/etcd/jetcd/JEtcdClient.java
index d0ec619..8f50017 100644
--- 
a/dubbo-remoting/dubbo-remoting-etcd3/src/main/java/org/apache/dubbo/remoting/etcd/jetcd/JEtcdClient.java
+++ 
b/dubbo-remoting/dubbo-remoting-etcd3/src/main/java/org/apache/dubbo/remoting/etcd/jetcd/JEtcdClient.java
@@ -278,7 +278,14 @@ public class JEtcdClient extends 
AbstractEtcdClient<JEtcdClient.EtcdWatcher> {
             }
 
             try {
-                this.listener = null;
+                /**
+                 * issue : 
https://github.com/apache/incubator-dubbo/issues/4115
+                 *
+                 * When the network is reconnected, the listener is empty
+                 * and the data cannot be received.
+                 */
+                // this.listener = null;
+
                 if (watchRequest != null) {
                     WatchCancelRequest watchCancelRequest =
                             
WatchCancelRequest.newBuilder().setWatchId(watchId).build();