Package com.networknt.zookeeper.client

Class ZooKeeperClientImpl

java.lang.Object

com.networknt.zookeeper.client.ZooKeeperClientImpl

All Implemented Interfaces:

ZooKeeperClient

public class ZooKeeperClientImpl
extends Object
implements ZooKeeperClient

ZooKeeperClient implementation.

Author:

Steve Hu

Constructor Summary

Constructors

Constructor	Description
ZooKeeperClientImpl(String zkServers, int sessionTimeout, int connectionTimeout)

Method Summary

Modifier and Type	Method	Description
void	createEphemeral(String path, Object data)
void	createPersistent(String path, boolean createParents)
boolean	delete(String path)
boolean	exists(String path)
List<String>	getChildren(String path)
int	getConnectionTimeout()
int	getSessionTimeout()
String	getZkServers()
<T> T	readData(String path)
<T> T	readData(String path, boolean returnNullIfPathNotExists)
void	setConnectionTimeout(int connectionTimeout)
void	setSessionTimeout(int sessionTimeout)
void	setZkServers(String zkServers)
List<String>	subscribeChildChanges(String path, org.I0Itec.zkclient.IZkChildListener listener)
void	subscribeDataChanges(String path, org.I0Itec.zkclient.IZkDataListener listener)
void	subscribeStateChanges(org.I0Itec.zkclient.IZkStateListener listener)
void	unsubscribeChildChanges(String path, org.I0Itec.zkclient.IZkChildListener childListener)
void	unsubscribeDataChanges(String path, org.I0Itec.zkclient.IZkDataListener dataListener)
void	writeData(String path, Object object)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZooKeeperClientImpl

public ZooKeeperClientImpl(String zkServers,
                           int sessionTimeout,
                           int connectionTimeout)

Method Detail

getZkServers

public String getZkServers()

setZkServers

public void setZkServers(String zkServers)

getSessionTimeout

public int getSessionTimeout()

setSessionTimeout

public void setSessionTimeout(int sessionTimeout)

getConnectionTimeout

public int getConnectionTimeout()

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

subscribeStateChanges

public void subscribeStateChanges(org.I0Itec.zkclient.IZkStateListener listener)

Specified by:

subscribeStateChanges in interface ZooKeeperClient

subscribeChildChanges

public List<String> subscribeChildChanges(String path,
                                          org.I0Itec.zkclient.IZkChildListener listener)

Specified by:

subscribeChildChanges in interface ZooKeeperClient

unsubscribeChildChanges

public void unsubscribeChildChanges(String path,
                                    org.I0Itec.zkclient.IZkChildListener childListener)

Specified by:

unsubscribeChildChanges in interface ZooKeeperClient

subscribeDataChanges

public void subscribeDataChanges(String path,
                                 org.I0Itec.zkclient.IZkDataListener listener)

Specified by:

subscribeDataChanges in interface ZooKeeperClient

unsubscribeDataChanges

public void unsubscribeDataChanges(String path,
                                   org.I0Itec.zkclient.IZkDataListener dataListener)

Specified by:

unsubscribeDataChanges in interface ZooKeeperClient

exists

public boolean exists(String path)

Specified by:

exists in interface ZooKeeperClient

getChildren

public List<String> getChildren(String path)

Specified by:

getChildren in interface ZooKeeperClient

readData

public <T> T readData(String path)

Specified by:

readData in interface ZooKeeperClient

readData

public <T> T readData(String path,
                      boolean returnNullIfPathNotExists)

Specified by:

readData in interface ZooKeeperClient

writeData

public void writeData(String path,
                      Object object)

Specified by:

writeData in interface ZooKeeperClient

createPersistent

public void createPersistent(String path,
                             boolean createParents)
                      throws org.I0Itec.zkclient.exception.ZkInterruptedException,
                             IllegalArgumentException,
                             org.I0Itec.zkclient.exception.ZkException,
                             RuntimeException

Specified by:

createPersistent in interface ZooKeeperClient

Throws:

org.I0Itec.zkclient.exception.ZkInterruptedException

IllegalArgumentException

org.I0Itec.zkclient.exception.ZkException

RuntimeException

createEphemeral

public void createEphemeral(String path,
                            Object data)
                     throws org.I0Itec.zkclient.exception.ZkInterruptedException,
                            IllegalArgumentException,
                            org.I0Itec.zkclient.exception.ZkException,
                            RuntimeException

Specified by:

createEphemeral in interface ZooKeeperClient

Throws:

org.I0Itec.zkclient.exception.ZkInterruptedException

IllegalArgumentException

org.I0Itec.zkclient.exception.ZkException

RuntimeException

delete

public boolean delete(String path)

Specified by:

delete in interface ZooKeeperClient