public abstract class QueueOperation extends AbstractNamedOperation implements PartitionAwareOperation, IdentifiedDataSerializable, NamedOperation
AddAllOperation
.Modifier and Type | Field and Description |
---|---|
protected Object |
response |
name
GENERIC_PARTITION_ID
Modifier | Constructor and Description |
---|---|
protected |
QueueOperation() |
protected |
QueueOperation(String name) |
protected |
QueueOperation(String name,
long timeoutMillis) |
Modifier and Type | Method and Description |
---|---|
void |
afterRun()
Is executed called after
Operation.run() or Operation.call() method completes normally and the operation is not
blocked, see CallStatus.WAIT . |
void |
beforeRun()
The beforeRun is called before either the
Operation.run() or the Operation.call() method is called. |
protected QueueContainer |
getContainer() |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
protected QueueService |
getQueueService() |
Object |
getResponse()
Called if and only if
Operation.returnsResponse() returned true ,
shortly after Operation.run() returns. |
String |
getServiceName() |
boolean |
hasListener() |
void |
publishEvent(ItemEventType eventType,
Data data) |
getName, readInternal, toString, writeInternal
call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, run, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
getId
readData, writeData
getName
protected transient Object response
protected QueueOperation()
protected QueueOperation(String name)
protected QueueOperation(String name, long timeoutMillis)
protected final QueueContainer getContainer()
public final Object getResponse()
Operation
Operation.returnsResponse()
returned true
,
shortly after Operation.run()
returns.getResponse
in class Operation
public final String getServiceName()
getServiceName
in class Operation
public void afterRun() throws Exception
Operation
Operation.run()
or Operation.call()
method completes normally and the operation is not
blocked, see CallStatus.WAIT
.
Runs after backups, before wait-notify.public void beforeRun() throws Exception
Operation
Operation.run()
or the Operation.call()
method is called.
runs before wait-supportpublic boolean hasListener()
public void publishEvent(ItemEventType eventType, Data data)
protected QueueService getQueueService()
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.