org.apache.s4.comm.topology
Class ZkClient

java.lang.Object
  extended by org.I0Itec.zkclient.ZkClient
      extended by org.apache.s4.comm.topology.ZkClient
All Implemented Interfaces:
org.apache.zookeeper.Watcher

public class ZkClient
extends org.I0Itec.zkclient.ZkClient

Overwriting the ZKclient since the org.I0Itec.zkclient.ZkClient does not expose some important methods


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
org.apache.zookeeper.Watcher.Event
 
Field Summary
 
Fields inherited from class org.I0Itec.zkclient.ZkClient
_connection
 
Constructor Summary
ZkClient(org.I0Itec.zkclient.IZkConnection connection)
           
ZkClient(org.I0Itec.zkclient.IZkConnection connection, int connectionTimeout)
           
ZkClient(org.I0Itec.zkclient.IZkConnection connection, int connectionTimeout, org.I0Itec.zkclient.serialize.ZkSerializer zkSerializer)
           
ZkClient(java.lang.String serverstring)
           
ZkClient(java.lang.String zkServers, int connectionTimeout)
           
ZkClient(java.lang.String zkServers, int sessionTimeout, int connectionTimeout)
           
 
Method Summary
 org.I0Itec.zkclient.IZkConnection getConnection()
           
 long getSessionId()
           
 org.apache.zookeeper.data.Stat getStat(java.lang.String path)
           
<T> T
readData(java.lang.String path, boolean returnNullIfPathNotExists)
           
 
Methods inherited from class org.I0Itec.zkclient.ZkClient
close, connect, countChildren, create, createEphemeral, createEphemeral, createEphemeralSequential, createPersistent, createPersistent, createPersistent, createPersistentSequential, delete, deleteRecursive, exists, exists, getChildren, getChildren, getCreationTime, getDataListener, getEventLock, getShutdownTrigger, numberOfListeners, process, readData, readData, readData, retryUntilConnected, setCurrentState, setShutdownTrigger, setZkSerializer, showFolders, subscribeChildChanges, subscribeDataChanges, subscribeStateChanges, unsubscribeAll, unsubscribeChildChanges, unsubscribeDataChanges, unsubscribeStateChanges, updateDataSerialized, waitForKeeperState, waitUntilConnected, waitUntilConnected, waitUntilExists, watchForChilds, watchForData, writeData, writeData
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZkClient

public ZkClient(org.I0Itec.zkclient.IZkConnection connection,
                int connectionTimeout,
                org.I0Itec.zkclient.serialize.ZkSerializer zkSerializer)

ZkClient

public ZkClient(org.I0Itec.zkclient.IZkConnection connection,
                int connectionTimeout)

ZkClient

public ZkClient(org.I0Itec.zkclient.IZkConnection connection)

ZkClient

public ZkClient(java.lang.String zkServers,
                int sessionTimeout,
                int connectionTimeout)

ZkClient

public ZkClient(java.lang.String zkServers,
                int connectionTimeout)

ZkClient

public ZkClient(java.lang.String serverstring)
Method Detail

getConnection

public org.I0Itec.zkclient.IZkConnection getConnection()

getSessionId

public long getSessionId()

getStat

public org.apache.zookeeper.data.Stat getStat(java.lang.String path)

readData

public <T> T readData(java.lang.String path,
                      boolean returnNullIfPathNotExists)
Overrides:
readData in class org.I0Itec.zkclient.ZkClient