public class MNReplicationTask extends Object implements Serializable, Callable<String>
Modifier and Type | Field and Description |
---|---|
static org.apache.log4j.Logger |
log |
Constructor and Description |
---|
MNReplicationTask()
Constructor - create an empty replication task instance
|
MNReplicationTask(String taskid,
org.dataone.service.types.v1.Identifier pid,
org.dataone.service.types.v1.NodeReference originatingNode,
org.dataone.service.types.v1.NodeReference targetNode)
Constructor - create a replication task instance
|
Modifier and Type | Method and Description |
---|---|
String |
call()
Implement the Callable interface, providing code that initiates
replication.
|
String |
getEventid()
Get the event identifier
|
org.dataone.service.types.v1.NodeReference |
getOriginatingNode()
Get the originating node
|
String |
getOriginatingNodeSubject()
For the given Replication task, return the Subject listed in the target
node.
|
org.dataone.service.types.v1.Identifier |
getPid()
Get the object identifier to be replicated
|
int |
getRetryCount()
Get the number of retries for this particular replication task;
|
org.dataone.service.types.v1.NodeReference |
getTargetNode()
Get the target node
|
String |
getTargetNodeSubject()
For the given Replication task, return the Subject listed in the target
node.
|
String |
getTaskid()
Get the task identifier for this task
|
void |
run()
Implements the Runnable interface, but the task is actually called via
the Callable interface.
|
void |
setEventid(String eventid)
Set the event identifier
|
void |
setOriginatingNode(org.dataone.service.types.v1.NodeReference originatingNode)
Set the originating node
|
void |
setOriginatingNodeSubject(String subject)
Set the target node subject identifying the node
|
void |
setRetryCount(int retryCount)
Set the number of retries for this particular replication task
|
void |
setTargetNode(org.dataone.service.types.v1.NodeReference targetNode)
Set the target node
|
void |
setTargetNodeSubject(String subject)
Set the target node subject identifying the node
|
void |
setTaskid(String taskid)
Set the task identifier for this task
|
public MNReplicationTask()
public MNReplicationTask(String taskid, org.dataone.service.types.v1.Identifier pid, org.dataone.service.types.v1.NodeReference originatingNode, org.dataone.service.types.v1.NodeReference targetNode)
taskid
- pid
- targetNode
- public String getTaskid()
public void setTaskid(String taskid)
taskid
- the taskid to setpublic org.dataone.service.types.v1.Identifier getPid()
public String getEventid()
public void setEventid(String eventid)
eventid
- the eventid to setpublic org.dataone.service.types.v1.NodeReference getTargetNode()
public void setTargetNode(org.dataone.service.types.v1.NodeReference targetNode)
targetNode
- the targetNode to setpublic org.dataone.service.types.v1.NodeReference getOriginatingNode()
public void setOriginatingNode(org.dataone.service.types.v1.NodeReference originatingNode)
originatingNode
- the originatingNode to setpublic String getTargetNodeSubject()
public void setTargetNodeSubject(String subject)
subject
- the targetNode subjectpublic String getOriginatingNodeSubject()
public void setOriginatingNodeSubject(String subject)
subject
- the targetNode subjectpublic String call()
public void run()
public void setRetryCount(int retryCount)
retryCount
- public int getRetryCount()
Copyright © 2018. All rights reserved.