
public class OSyncDatabaseTask extends OAbstractReplicatedTask implements OCommandOutputListener
ORemoteTask.RESULT_STRATEGY| Modifier and Type | Field and Description |
|---|---|
static int |
CHUNK_MAX_SIZE |
static String |
DEPLOYDB |
static int |
FACTORYID |
protected long |
random |
nodeSource| Constructor and Description |
|---|
OSyncDatabaseTask() |
| Modifier and Type | Method and Description |
|---|---|
Object |
execute(ODistributedRequestId requestId,
OServer iServer,
ODistributedServerManager iManager,
ODatabaseDocumentTx database) |
long |
getDistributedTimeout() |
int |
getFactoryId() |
String |
getName() |
String |
getPayload() |
OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType() |
ORemoteTask.RESULT_STRATEGY |
getResultStrategy() |
boolean |
isNodeOnlineRequired() |
void |
onMessage(String iText) |
void |
readExternal(ObjectInput in) |
void |
writeExternal(ObjectOutput out) |
getFixTask, getUndoTaskgetNodeSource, getPartitionKey, getSynchronousTimeout, getTotalTimeout, isIdempotent, setNodeSource, toStringpublic static final int CHUNK_MAX_SIZE
public static final String DEPLOYDB
public static final int FACTORYID
protected long random
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentTx database) throws Exception
execute in interface ORemoteTaskexecute in class OAbstractRemoteTaskExceptionpublic ORemoteTask.RESULT_STRATEGY getResultStrategy()
getResultStrategy in interface ORemoteTaskgetResultStrategy in class OAbstractRemoteTaskpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
getQuorumType in interface ORemoteTaskgetQuorumType in class OAbstractRemoteTaskpublic long getDistributedTimeout()
getDistributedTimeout in interface ORemoteTaskgetDistributedTimeout in class OAbstractRemoteTaskpublic String getPayload()
getPayload in class OAbstractReplicatedTaskpublic String getName()
getName in interface ORemoteTaskgetName in class OAbstractRemoteTaskpublic void writeExternal(ObjectOutput out) throws IOException
writeExternal in interface ExternalizableIOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizableIOExceptionClassNotFoundExceptionpublic void onMessage(String iText)
onMessage in interface OCommandOutputListenerpublic boolean isNodeOnlineRequired()
isNodeOnlineRequired in interface ORemoteTaskisNodeOnlineRequired in class OAbstractRemoteTaskpublic int getFactoryId()
getFactoryId in interface ORemoteTaskCopyright © 2009–2016 Orient Technologies. All rights reserved.