1
1
package com .ikasoa .zk ;
2
2
3
- import java .util .ArrayList ;
4
3
import java .util .List ;
5
4
6
5
import org .I0Itec .zkclient .IZkChildListener ;
@@ -64,7 +63,7 @@ public void handleDataDeleted(String nodePath) throws Exception {
64
63
65
64
@ Override
66
65
public void handleNewSession () throws Exception {
67
- log .debug ("handleNewSession" );
66
+ log .debug ("Implementing ' handleNewSession' . " );
68
67
nodeList = getChildren ();
69
68
}
70
69
@@ -75,7 +74,7 @@ public void handleSessionEstablishmentError(Throwable t) throws Exception {
75
74
76
75
@ Override
77
76
public void handleStateChanged (KeeperState state ) throws Exception {
78
- log .debug ("handleStateChanged (state : {})" , state );
77
+ log .debug ("Implementing ' handleStateChanged (state : {})' . " , state );
79
78
}
80
79
81
80
});
@@ -84,7 +83,8 @@ public void handleStateChanged(KeeperState state) throws Exception {
84
83
85
84
@ Override
86
85
public void handleChildChange (String parentPath , List <String > currentChildList ) throws Exception {
87
- log .debug ("handleChildChange (parentPath : {}, currentChildList : {})" , parentPath , currentChildList );
86
+ log .debug ("Implementing 'handleChildChange (parentPath : {}, currentChildList : {})' ." , parentPath ,
87
+ currentChildList );
88
88
nodeList = currentChildList ;
89
89
}
90
90
@@ -96,8 +96,7 @@ public List<ServerInfo> getServerInfoList() {
96
96
List <ServerInfo > serverInfoList = ListUtil .newArrayList ();
97
97
List <String > nList = zkClient .getChildren (zkNode );
98
98
for (String n : nList ) {
99
- ZkServerNode zksn = (ZkServerNode ) zkClient
100
- .readData (new StringBuilder (zkNode ).append ("/" ).append (n ).toString ());
99
+ ZkServerNode zksn = (ZkServerNode ) zkClient .readData (StringUtil .merge (zkNode , "/" , n ));
101
100
serverInfoList .add (new ServerInfo (zksn .getServerHost (), zksn .getServerPort ()));
102
101
}
103
102
log .debug ("ServerInfoList is : {}" , serverInfoList );
0 commit comments