com.bigdata.jini.start
Class MonitorConfigZNodeTask

java.lang.Object
  com.bigdata.jini.start.MonitorConfigZNodeTask

All Implemented Interfaces:

Callable<Void>

public class MonitorConfigZNodeTask
extends Object
implements Callable<Void>

Task monitors the BigdataZooDefs.CONFIG znode and creates a new ServiceConfigurationZNodeMonitorTask each time a new child is created. The data for those children are ServiceConfigurations.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

protected static boolean	DEBUG
protected static boolean	INFO
protected static org.apache.log4j.Logger	log

Constructor Summary

MonitorConfigZNodeTask(JiniFederation fed, IServiceListener listener)

Method Summary

Void	call() Start monitoring the BigdataZooDefs.CONFIG znode.
void	handleNewConfigZNode(String serviceConfigZPath) Create a ServiceConfigurationZNodeMonitorTask for a specific service config node and submits it for execution.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

INFO

protected static final boolean INFO

DEBUG

protected static final boolean DEBUG

Constructor Detail

MonitorConfigZNodeTask

public MonitorConfigZNodeTask(JiniFederation fed,
                              IServiceListener listener)

Method Detail

call

public Void call()
          throws Exception

Start monitoring the BigdataZooDefs.CONFIG znode.

Note: If the znode does not exist or ZooKeeper is not connected, then the task will keep trying to establish it watch until the znode is created.

Note: This task runs until cancelled.

Specified by:

call in interface Callable<Void>

Throws:

Exception

handleNewConfigZNode

public void handleNewConfigZNode(String serviceConfigZPath)
                          throws org.apache.zookeeper.KeeperException,
                                 InterruptedException

Create a ServiceConfigurationZNodeMonitorTask for a specific service config node and submits it for execution.

Parameters:

serviceConfigZPath - The zpath to the new ServiceConfiguration znode.

Throws:

InterruptedException

org.apache.zookeeper.KeeperException