org.dataone.cn.batch.synchronization

Class NodeCommObjectListHarvestFactory

java.lang.Object

org.dataone.cn.batch.synchronization.NodeCommObjectListHarvestFactory

All Implemented Interfaces:

NodeCommFactory

public class NodeCommObjectListHarvestFactory
extends Object
implements NodeCommFactory

Creates a NodeComm (node communications) bundle for use by the ObjectListHarvestTask. A NodeComm object is memberNode specific Sets up instances that should be reused by the ObjectListHarvestTask. Assume that most of the bundled instances (mNode/nodeRegistry) are not thread-safe, in other words the instances created by this factory will be re-used by threads, but no two concurrent threads should access the same instances (with the exception of hazelcast client instance)

Author:

waltz

Method Summary

Modifier and Type	Method and Description
static NodeCommFactory	getInstance()
NodeComm	getNodeComm(org.dataone.service.types.v1.NodeReference mnNodeId)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static NodeCommFactory getInstance()

getNodeComm

public NodeComm getNodeComm(org.dataone.service.types.v1.NodeReference mnNodeId)
                     throws org.dataone.service.exceptions.ServiceFailure,
                            NodeCommUnavailable

Specified by:

getNodeComm in interface NodeCommFactory

Throws:

org.dataone.service.exceptions.ServiceFailure

NodeCommUnavailable