public abstract class QueueOperation extends Operation implements PartitionAwareOperation, IdentifiedDataSerializable
AddAllOperation
.Modifier and Type | Field and Description |
---|---|
protected String |
name |
protected Object |
response |
CALL_ID_LOCAL_SKIPPED, 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() |
void |
beforeRun() |
int |
getFactoryId()
Returns DataSerializableFactory factory id for this class.
|
String |
getName() |
protected QueueContainer |
getOrCreateContainer() |
protected QueueService |
getQueueService() |
Object |
getResponse() |
String |
getServiceName() |
boolean |
hasListener() |
void |
publishEvent(ItemEventType eventType,
Data data) |
protected void |
readInternal(ObjectDataInput in) |
boolean |
returnsResponse() |
protected void |
writeInternal(ObjectDataOutput out) |
getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, onExecutionFailure, onInvocationException, onSetCallId, readData, run, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
getId
readData, writeData
protected QueueOperation()
protected QueueOperation(String name)
protected QueueOperation(String name, long timeoutMillis)
protected final QueueContainer getOrCreateContainer()
public boolean returnsResponse()
returnsResponse
in class Operation
public final Object getResponse()
getResponse
in class Operation
public final String getServiceName()
getServiceName
in class Operation
public final String getName()
public void afterRun() throws Exception
public void beforeRun() throws Exception
public boolean hasListener()
public void publishEvent(ItemEventType eventType, Data data)
protected QueueService getQueueService()
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class Operation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class Operation
IOException
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.