Package org.dataone.cn.batch.synchronization.tasks

Class Summary

Class	Description
DelayWrapper<T>	A wrapper class for objects that implements Delayed.
ObjectListHarvestTask	An executable task that retrieve a list of ObjectInfos by calling listObject on a MN and then submits them on the SyncTaskQueue for processing.
QueueProcessorCallable<E,V>	A Callable for executing a Queue processing loop using a ThreadPoolTaskExecutor.
SortedHarvestTimepointMap	This class represents a high-level type for the items retrieved in a MemberNode harvest.
SyncFailedTask	This is a callable class to report back to the MN when a failure has occurred during synchronization.
SyncMetricLogReport	Create a Report of the number of tasks queued for processing per MemberNode and a total of tasks queued for the processor
SyncObjectTask	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.
TransferObjectTask	Transfer an object from a MemberNode(MN) to a CoordinatingNode(CN).
V2TransferObjectTask	Transfer an object from a MemberNode(MN) to a CoordinatingNode(CN).