com.hazelcast.cache.impl.operation

Class AbstractMutatingCacheOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.impl.AbstractNamedOperation

com.hazelcast.cache.impl.operation.AbstractCacheOperation

com.hazelcast.cache.impl.operation.AbstractMutatingCacheOperation

All Implemented Interfaces:

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

Direct Known Subclasses:

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

public abstract class AbstractMutatingCacheOperation
extends AbstractCacheOperation
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.AbstractCacheOperation

backupRecord, cache, cacheService, key, response, 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	AbstractMutatingCacheOperation()
protected	AbstractMutatingCacheOperation(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.AbstractCacheOperation

beforeRun, getAsyncBackupCount, getFactoryId, getResponse, getServiceName, getServiceNamespace, getSyncBackupCount, logError, onInvocationException

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, 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

AbstractMutatingCacheOperation

protected AbstractMutatingCacheOperation()

AbstractMutatingCacheOperation

protected AbstractMutatingCacheOperation(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 AbstractCacheOperation

Throws:

IOException

readInternal

protected void readInternal(ObjectDataInput in)
                     throws IOException

Overrides:

readInternal in class AbstractCacheOperation

Throws:

IOException