From ade85d646e60e5d1632d81997080e994aa71afc8 Mon Sep 17 00:00:00 2001
From: "vito.he" <hxmhlt@163.com>
Date: Sun, 26 Jan 2020 23:53:56 +0800
Subject: [PATCH] modify zk ListenServiceEvent
---
remoting/zookeeper/listener.go | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/remoting/zookeeper/listener.go b/remoting/zookeeper/listener.go
index 34c75fcea..ece81eb22 100644
--- a/remoting/zookeeper/listener.go
+++ b/remoting/zookeeper/listener.go
@@ -114,8 +114,9 @@ func (l *ZkEventListener) handleZkNodeEvent(zkPath string, children []string, li
content, _, err := l.client.Conn.Get(zkPath)
if err != nil {
logger.Errorf("Get new node path {%v} 's content error,message is {%v}", zkPath, perrors.WithStack(err))
+ } else {
+ listener.DataChange(remoting.Event{Path: zkPath, Action: remoting.EventTypeUpdate, Content: string(content)})
}
- listener.DataChange(remoting.Event{Path: zkPath, Action: remoting.EventTypeUpdate, Content: string(content)})
} else {
logger.Errorf("path{%s} child nodes changed, zk.Children() = error{%v}", zkPath, perrors.WithStack(err))
--
GitLab