com.aspc.remote.task

Class SyncManager

java.lang.Object

com.aspc.remote.task.TaskManager

com.aspc.remote.task.SyncManager

All Implemented Interfaces:

java.lang.Runnable

public class SyncManager
extends TaskManager
implements java.lang.Runnable

SyncManager looks after the session life cycle for a task, and will call the handleTask method of the TaskHandler when it gets a transaction record from TASK NEXT.
THREAD MODE: MULTI-THREADED

Since:

28 September 2005

Author:

luke

Field Summary

Fields

Modifier and Type	Field and Description
protected TaskHandler	handler TaskHandler instance that will be called to process a task

Fields inherited from class com.aspc.remote.task.TaskManager

pool, task, trans_ms, transid

Constructor Summary

Constructors

Constructor and Description
SyncManager(java.lang.String taskCode, PoolableObjectFactory factory, TaskHandler handler) Creates a new SyncManager.
SyncManager(java.lang.String taskCode, java.lang.String hosts, TaskHandler handler) Creates a new SyncManager.

Method Summary

Modifier and Type	Method and Description
long	getTimeout() Gets the timeout that is used when the main loop goes to sleep
void	kill() Sets a flag indicating that the sync manager should stop.
void	listen() Starts the main processing loop for the sync manager, created in a new thread.
boolean	listening() Checks to see if this sync manager is listening
void	run() The main task processing loop for the sync manager
void	setTimeout(long milliseconds) Sets the timeout value that is used when the main loop goes to sleep negative values will be silently ignored, and the timeout will not change
void	wakeUp() Calls notify on this object, to wake up the main loop if it is in wait

Methods inherited from class com.aspc.remote.task.TaskManager

alive, getParameters, incrementalBeat, taskBeat, taskEnd, taskError, taskNext, taskSession, taskStart

Methods inherited from class java.lang.Object

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

Field Detail

handler

protected TaskHandler handler

TaskHandler instance that will be called to process a task

Constructor Detail

SyncManager

public SyncManager(java.lang.String taskCode,
                   java.lang.String hosts,
                   TaskHandler handler)

Creates a new SyncManager. It uses the hosts String to create a ClientFactory

Parameters:

taskCode - the code for this task

hosts - the hosts string used to make new Client objects by ClientFactory

handler - the task handler that will be called when a task is ready to be processed

SyncManager

public SyncManager(java.lang.String taskCode,
                   PoolableObjectFactory factory,
                   TaskHandler handler)

Creates a new SyncManager.

Parameters:

taskCode - the code for this task

factory - the factory used by the internal ExecutorPool for Executor objects

handler - the task handler that will be called when a task is ready to be processed

Method Detail

run

public void run()

The main task processing loop for the sync manager

Specified by:

run in interface java.lang.Runnable

listen

public void listen()

Starts the main processing loop for the sync manager, created in a new thread. Only one main loop thread will be alive at a time. If a main loop thread already exists and is alive, this call does nothing.

wakeUp

public void wakeUp()

Calls notify on this object, to wake up the main loop if it is in wait

getTimeout

public long getTimeout()

Gets the timeout that is used when the main loop goes to sleep

Returns:

long the current timeout value

setTimeout

public void setTimeout(long milliseconds)

Sets the timeout value that is used when the main loop goes to sleep negative values will be silently ignored, and the timeout will not change

Parameters:

milliseconds - the new timeout in milliseconds

listening

public boolean listening()

Checks to see if this sync manager is listening

Returns:

boolean true if this task manager is listening

kill

public void kill()

Sets a flag indicating that the sync manager should stop.