com.orientechnologies.orient.server.distributed.impl
Class OSynchronizedTaskWrapper
public class OSynchronizedTaskWrapper extends OAbstractRemoteTask
ORemoteTask.RESULT_STRATEGYnodeSource| Constructor and Description |
|---|
OSynchronizedTaskWrapper(CountDownLatch iLatch) |
OSynchronizedTaskWrapper(CountDownLatch iLatch,
String iNodeName,
ORemoteTask iTask) |
| Modifier and Type | Method and Description |
|---|---|
Object |
execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
int |
getFactoryId() |
String |
getName() |
OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType() |
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
getDistributedTimeout, getNodeSource, getPartitionKey, getResultStrategy, getSynchronousTimeout, getTotalTimeout, isIdempotent, isNodeOnlineRequired, setNodeSource, toStringpublic OSynchronizedTaskWrapper(CountDownLatch iLatch, String iNodeName, ORemoteTask iTask)
public OSynchronizedTaskWrapper(CountDownLatch iLatch)
public String getName()
getName in interface ORemoteTaskgetName in class OAbstractRemoteTaskpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType in class OAbstractRemoteTaskpublic Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskexecute in class OAbstractRemoteTaskExceptionpublic int getFactoryId()
public void writeExternal(ObjectOutput out) throws IOException
IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionCopyright © 2009–2016 Orient Technologies. All rights reserved.