T
- The data type that is being watched.public final class ContentWatcher<T> extends java.lang.Object implements IZkDataListener
Constructor and Description |
---|
ContentWatcher(ZkClient zkClient,
java.lang.String fileName) |
Modifier and Type | Method and Description |
---|---|
T |
getContent() |
void |
handleDataChange(java.lang.String dataPath,
java.lang.Object data) |
void |
handleDataDeleted(java.lang.String dataPath) |
void |
setContent(T data) |
void |
start() |
void |
stop() |
public ContentWatcher(ZkClient zkClient, java.lang.String fileName)
public void start()
public void stop()
public void setContent(T data)
public void handleDataChange(java.lang.String dataPath, java.lang.Object data)
handleDataChange
in interface IZkDataListener
public void handleDataDeleted(java.lang.String dataPath)
handleDataDeleted
in interface IZkDataListener
public T getContent() throws java.lang.InterruptedException
java.lang.InterruptedException