Package org.I0Itec.zkclient

Examples of org.I0Itec.zkclient.ZkClient.subscribeChildChanges()

156
157
158
159
160
161
162
163
164
165
166
      {
        System.out.println("listener2 Change at path:" + parentPath);
      }
    };

    client.subscribeChildChanges("/", listener1);
    client.subscribeChildChanges("/foo", listener2);

    // server.shutdown();
    client.waitForKeeperState(KeeperState.Disconnected, 20000,
        TimeUnit.MILLISECONDS);
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
        System.out.println("listener2 Change at path:" + parentPath);
      }
    };

    client.subscribeChildChanges("/", listener1);
    client.subscribeChildChanges("/foo", listener2);

    // server.shutdown();
    client.waitForKeeperState(KeeperState.Disconnected, 20000,
        TimeUnit.MILLISECONDS);
    // server.start();
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
            System.out.println(parentPath + " path exists and will be deleted");
            zkClient.deleteRecursive(parentPath);
        }
        zkClient.createPersistent(parentPath);
        final CountDownLatch signalReady = new CountDownLatch(1);
        zkClient.subscribeChildChanges(parentPath, new IZkChildListener() {

            @Override
            public void handleChildChange(String arg0, List<String> arg1) throws Exception {

                if (parentPath.equals(arg0)) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.