public class AwaitOperation extends AbstractNamedOperation implements BlockingOperation, ReadonlyOperation
nameGENERIC_PARTITION_ID| Constructor and Description |
|---|
AwaitOperation() |
AwaitOperation(String name,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
Object |
getResponse()
Called if and only if
Operation.returnsResponse() returned true,
shortly after Operation.run() returns. |
String |
getServiceName() |
WaitNotifyKey |
getWaitKey() |
void |
onWaitExpire() |
void |
run()
Runs the operation.
|
boolean |
shouldWait() |
getName, readInternal, toString, writeInternalafterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetWaitTimeoutgetPartitionIdreadData, writeDatapublic AwaitOperation()
public AwaitOperation(String name, long timeout)
public void run()
throws Exception
OperationOperation.run() or Operation.call() method should be implemented; not both.
Runs after wait-support, supposed to do actual operationrun in class OperationExceptionOperation.call()public Object getResponse()
OperationOperation.returnsResponse() returned true,
shortly after Operation.run() returns.getResponse in class Operationpublic WaitNotifyKey getWaitKey()
getWaitKey in interface BlockingOperationpublic boolean shouldWait()
shouldWait in interface BlockingOperationpublic void onWaitExpire()
onWaitExpire in interface BlockingOperationpublic int getId()
IdentifiedDataSerializablegetId in interface IdentifiedDataSerializablepublic final String getServiceName()
getServiceName in class Operationpublic final int getFactoryId()
IdentifiedDataSerializablegetFactoryId in interface IdentifiedDataSerializableCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.