Skip to content
Snippets Groups Projects
Commit c65c5fee authored by 邹毅贤's avatar 邹毅贤
Browse files

Merge pull request #735 from wenxuwan/master 

Fix: #734
parent 47247be8
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
remoting/zookeeper/listener.go
+ 1
− 1
View file @ c65c5fee
...@@ -322,7 +322,7 @@ func (l *ZkEventListener) listenDirEvent(conf *common.URL, zkPath string, listen ...@@ -322,7 +322,7 @@ func (l *ZkEventListener) listenDirEvent(conf *common.URL, zkPath string, listen
for { for {
select { select {
case <-ticker.C: case <-ticker.C:
l.handleZkNodeEvent(zkEvent.Path, children, listener) l.handleZkNodeEvent(zkPath, children, listener)
case zkEvent = <-childEventCh: case zkEvent = <-childEventCh:
logger.Warnf("get a zookeeper zkEvent{type:%s, server:%s, path:%s, state:%d-%s, err:%s}", logger.Warnf("get a zookeeper zkEvent{type:%s, server:%s, path:%s, state:%d-%s, err:%s}",
zkEvent.Type.String(), zkEvent.Server, zkEvent.Path, zkEvent.State, StateToString(zkEvent.State), zkEvent.Err) zkEvent.Type.String(), zkEvent.Server, zkEvent.Path, zkEvent.State, StateToString(zkEvent.State), zkEvent.Err)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment