public class ZookeeperGroupListenerSupport extends ZookeeperGroupSupport implements GroupListener
GroupListener.GroupEvent
Constructor and Description |
---|
ZookeeperGroupListenerSupport(String clusterPath,
org.apache.camel.Endpoint endpoint,
Runnable onLockAcquired,
Runnable onDisconnected) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
String |
getClusterPath() |
Group<CamelNodeState> |
getGroup() |
void |
groupEvent(Group group,
GroupListener.GroupEvent event) |
protected void |
onDisconnected() |
protected void |
onLockOwned() |
void |
updateState(CamelNodeState state) |
call, createGroup, getCamelContext, getCurator, getMaximumConnectionTimeout, getZooKeeperPassword, getZooKeeperUrl, registerAsListener, setCamelContext, setCurator, setMaximumConnectionTimeout, setZooKeeperPassword, setZooKeeperUrl, stateChanged
public void updateState(CamelNodeState state)
protected void doStart() throws Exception
doStart
in class ZookeeperGroupSupport
Exception
protected void doStop() throws Exception
doStop
in class ZookeeperGroupSupport
Exception
public String getClusterPath()
public Group<CamelNodeState> getGroup()
public void groupEvent(Group group, GroupListener.GroupEvent event)
groupEvent
in interface GroupListener
protected void onDisconnected()
protected void onLockOwned()
Apache Camel