com.hazelcast.cache.impl.operation

Class MutatingCacheOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.impl.AbstractNamedOperation

com.hazelcast.cache.impl.operation.CacheOperation

com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

com.hazelcast.cache.impl.operation.MutatingCacheOperation

All Implemented Interfaces:

MutableOperation, DataSerializable, IdentifiedDataSerializable, BackupAwareOperation, MutatingOperation, NamedOperation, PartitionAwareOperation, ServiceNamespaceAware

Direct Known Subclasses:

CacheEntryProcessorOperation, CacheGetAndRemoveOperation, CacheGetAndReplaceOperation, CachePutIfAbsentOperation, CachePutOperation, CacheRemoveOperation, CacheReplaceOperation

public abstract class MutatingCacheOperation
extends KeyBasedCacheOperation
implements BackupAwareOperation, MutableOperation, MutatingOperation

Base class for all mutable cache operations. Main purpose of this abstract class is providing the completion event functionality.

This operation publishes COMPLETE event.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	completionId

Fields inherited from class com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

backupRecord, key, response

Fields inherited from class com.hazelcast.cache.impl.operation.CacheOperation

cacheService, dontCreateCacheRecordStoreIfNotExist, recordStore, wanEventPublisher

Fields inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

name

Fields inherited from class com.hazelcast.spi.Operation

GENERIC_PARTITION_ID

Fields inherited from interface com.hazelcast.cache.impl.operation.MutableOperation

IGNORE_COMPLETION

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MutatingCacheOperation()
protected	MutatingCacheOperation(String name, Data key, int completionId)

Method Summary

Modifier and Type	Method and Description
int	getCompletionId()
protected void	readInternal(ObjectDataInput in)
void	setCompletionId(int completionId)
protected void	writeInternal(ObjectDataOutput out)

Methods inherited from class com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

getResponse

Methods inherited from class com.hazelcast.cache.impl.operation.CacheOperation

beforeRun, beforeRunInternal, dispose, getAsyncBackupCount, getFactoryId, getServiceName, getServiceNamespace, getSyncBackupCount, logError, onInvocationException, publishWanRemove, publishWanUpdate, publishWanUpdate, publishWanUpdate

Methods inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

getName, toString

Methods inherited from class com.hazelcast.spi.Operation

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.spi.BackupAwareOperation

getAsyncBackupCount, getBackupOperation, getSyncBackupCount, shouldBackup

Methods inherited from interface com.hazelcast.spi.PartitionAwareOperation

getPartitionId

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Field Detail

completionId

protected int completionId

Constructor Detail

MutatingCacheOperation

protected MutatingCacheOperation()

MutatingCacheOperation

protected MutatingCacheOperation(String name,
                                 Data key,
                                 int completionId)

Method Detail

getCompletionId

public int getCompletionId()

Specified by:

getCompletionId in interface MutableOperation

setCompletionId

public void setCompletionId(int completionId)

Specified by:

setCompletionId in interface MutableOperation

writeInternal

protected void writeInternal(ObjectDataOutput out)
                      throws IOException

Overrides:

writeInternal in class KeyBasedCacheOperation

Throws:

IOException

readInternal

protected void readInternal(ObjectDataInput in)
                     throws IOException

Overrides:

readInternal in class KeyBasedCacheOperation

Throws:

IOException