public abstract class MutatingCacheOperation extends KeyBasedCacheOperation implements BackupAwareOperation, MutableOperation, MutatingOperation
This operation publishes COMPLETE event.
Modifier and Type | Field and Description |
---|---|
protected int |
completionId |
backupRecord, key, response
cacheService, dontCreateCacheRecordStoreIfNotExist, recordStore, wanEventPublisher
name
GENERIC_PARTITION_ID
IGNORE_COMPLETION
Modifier | Constructor and Description |
---|---|
protected |
MutatingCacheOperation() |
protected |
MutatingCacheOperation(String name,
Data key,
int completionId) |
Modifier and Type | Method and Description |
---|---|
int |
getCompletionId() |
protected void |
readInternal(ObjectDataInput in) |
void |
setCompletionId(int completionId) |
protected void |
writeInternal(ObjectDataOutput out) |
getResponse
beforeRun, beforeRunInternal, dispose, getAsyncBackupCount, getFactoryId, getServiceName, getServiceNamespace, getSyncBackupCount, logError, onInvocationException, publishWanRemove, publishWanUpdate, publishWanUpdate, publishWanUpdate
getName, toString
afterRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, onExecutionFailure, 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
getAsyncBackupCount, getBackupOperation, getSyncBackupCount, shouldBackup
getPartitionId
getId
readData, writeData
public int getCompletionId()
getCompletionId
in interface MutableOperation
public void setCompletionId(int completionId)
setCompletionId
in interface MutableOperation
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class KeyBasedCacheOperation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class KeyBasedCacheOperation
IOException
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.