public class ZooKeeperEphemeralNodePool extends Object
Modifier and Type | Field and Description |
---|---|
protected Map<String,ZooKeeperEphemeralNodeObject> |
nodes |
protected ZooKeeperConnectionPool |
pool |
Constructor and Description |
---|
ZooKeeperEphemeralNodePool(ZooKeeperConnectionPool pool) |
Modifier and Type | Method and Description |
---|---|
void |
createNode(String nodePath,
byte[] nodeData) |
void |
deleteAll() |
void |
deleteNode(String nodePath) |
protected ZooKeeperEphemeralNodeObject |
getObject(String nodePath) |
void |
setNodeData(String nodePath,
byte[] nodeData) |
protected final ZooKeeperConnectionPool pool
protected final Map<String,ZooKeeperEphemeralNodeObject> nodes
public ZooKeeperEphemeralNodePool(ZooKeeperConnectionPool pool)
public void createNode(String nodePath, byte[] nodeData) throws ManifoldCFException, InterruptedException
public void setNodeData(String nodePath, byte[] nodeData) throws ManifoldCFException, InterruptedException
public void deleteNode(String nodePath) throws ManifoldCFException, InterruptedException
public void deleteAll() throws ManifoldCFException, InterruptedException
protected ZooKeeperEphemeralNodeObject getObject(String nodePath)