public class EWRQueueReplicationOperation
extends com.hazelcast.spi.Operation
implements com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.nio.serialization.impl.Versioned
| Constructor and Description |
|---|
EWRQueueReplicationOperation() |
EWRQueueReplicationOperation(Collection<com.hazelcast.config.WanReplicationConfig> wanConfigs,
EWRMigrationContainer ewrMigrationContainer,
int partitionId,
int replicaIndex) |
| Modifier and Type | Method and Description |
|---|---|
int |
getFactoryId() |
int |
getId() |
protected void |
readInternal(com.hazelcast.nio.ObjectDataInput in) |
void |
run() |
protected void |
writeInternal(com.hazelcast.nio.ObjectDataOutput out) |
afterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getServiceName, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeDatapublic EWRQueueReplicationOperation()
public EWRQueueReplicationOperation(Collection<com.hazelcast.config.WanReplicationConfig> wanConfigs, EWRMigrationContainer ewrMigrationContainer, int partitionId, int replicaIndex)
public void run()
throws Exception
run in class com.hazelcast.spi.OperationExceptionpublic int getFactoryId()
getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializablepublic int getId()
getId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializableprotected void writeInternal(com.hazelcast.nio.ObjectDataOutput out)
throws IOException
writeInternal in class com.hazelcast.spi.OperationIOExceptionprotected void readInternal(com.hazelcast.nio.ObjectDataInput in)
throws IOException
readInternal in class com.hazelcast.spi.OperationIOExceptionCopyright © 2021 Hazelcast, Inc.. All Rights Reserved.