org.kuali.hr.time.batch
Class TkBatchManager

java.lang.Object
  org.kuali.hr.time.batch.TkBatchManager

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class TkBatchManager
extends Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Spring Bean to fire upon initialization. Runs on each worker node, manages runables with the ExecutorService.

Field Summary

static String	BATCH_DAY_WINDOW_FOR_POLLING_PARAM
static String	BATCH_MASTER_POLL_SLEEP_PARAM
static String	BATCH_POLLER_SLEEP_PARAM
static String	BATCH_WORK_STARUP_SLEEP
static String	MESSAGE_QUEUE_CHECKER_IP_PARAM
static String	WORKER_THREAD_POOL_SIZE_PARAM

Constructor Summary

TkBatchManager()

Method Summary

void	afterPropertiesSet()
void	destroy()
boolean	isMasterBatchNode() Helper method to determine whether the current machine is the master node, namely, the node that will create all BatchJobEntries to run on the worker nodes.

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_QUEUE_CHECKER_IP_PARAM

public static final String MESSAGE_QUEUE_CHECKER_IP_PARAM

See Also:

Constant Field Values

WORKER_THREAD_POOL_SIZE_PARAM

public static final String WORKER_THREAD_POOL_SIZE_PARAM

See Also:

Constant Field Values

BATCH_POLLER_SLEEP_PARAM

public static final String BATCH_POLLER_SLEEP_PARAM

See Also:

Constant Field Values

BATCH_MASTER_POLL_SLEEP_PARAM

public static final String BATCH_MASTER_POLL_SLEEP_PARAM

See Also:

Constant Field Values

BATCH_DAY_WINDOW_FOR_POLLING_PARAM

public static final String BATCH_DAY_WINDOW_FOR_POLLING_PARAM

See Also:

Constant Field Values

BATCH_WORK_STARUP_SLEEP

public static final String BATCH_WORK_STARUP_SLEEP

See Also:

Constant Field Values

Constructor Detail

TkBatchManager

public TkBatchManager()

Method Detail

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

isMasterBatchNode

public boolean isMasterBatchNode()

Helper method to determine whether the current machine is the master node, namely, the node that will create all BatchJobEntries to run on the worker nodes.

Returns:

true if this node is the master node.