org.dataone.cn.batch.synchronization.tasks

Class SyncObjectTask

java.lang.Object

org.dataone.cn.batch.synchronization.tasks.SyncObjectTask

All Implemented Interfaces:

Callable<String>

public class SyncObjectTask
extends Object
implements Callable<String>

Regulates the processing of the hzSyncObjectQueue by assigning SyncObjects to available resources (NodeComms), submitting FutureTasks to (SpringFramework) task executor, and managing task-related processing failures. It regulates execution scheduling by throttling the number of connections per MemberNode to maxNumberOfClientsPerMemberNode (a bean-property), and also canceling tasks that are taking too long to complete. Instances of this class that are call()'ed run as a daemon thread by the SyncObjectTaskManager, and the call() method uses an infinite loop that gracefully exits upon exception. It is also designed/needs to inter-operate with other SyncObjectTasks from other CN cluster members.

Author:

waltz

Constructor Summary

Constructors

Constructor and Description
SyncObjectTask()

Method Summary

Modifier and Type	Method and Description
String	call() Method to be called in a separately executing thread.
Integer	getMaxNumberOfClientsPerMemberNode()
NodeCommFactory	getNodeCommunicationsFactory()
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor	getThreadPoolTaskExecutor()
void	setMaxNumberOfClientsPerMemberNode(Integer maxNumberOfClientsPerMemberNode)
void	setNodeCommunicationsFactory(NodeCommFactory nodeCommunicationsFactory)
void	setThreadPoolTaskExecutor(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncObjectTask

public SyncObjectTask()

Method Detail

call

public String call()
            throws org.dataone.cn.batch.exceptions.ExecutionDisabledException

Method to be called in a separately executing thread.

Specified by:

call in interface Callable<String>

Returns:

String

Throws:

org.dataone.cn.batch.exceptions.ExecutionDisabledException

Exception

getThreadPoolTaskExecutor

public org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor getThreadPoolTaskExecutor()

setThreadPoolTaskExecutor

public void setThreadPoolTaskExecutor(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor)

getMaxNumberOfClientsPerMemberNode

public Integer getMaxNumberOfClientsPerMemberNode()

setMaxNumberOfClientsPerMemberNode

public void setMaxNumberOfClientsPerMemberNode(Integer maxNumberOfClientsPerMemberNode)

getNodeCommunicationsFactory

public NodeCommFactory getNodeCommunicationsFactory()

setNodeCommunicationsFactory

public void setNodeCommunicationsFactory(NodeCommFactory nodeCommunicationsFactory)