public class WanAntiEntropyEventPublishOperation
extends com.hazelcast.spi.Operation
implements com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.impl.AllowedDuringPassiveState
This operation merely is concerned with publishing the event on all partitions. Whether the event is fully processed when this method returns depends on the semantics of processing each event type. In case of WAN sync event, the sync is not complete when this method returns. After this method returns, entries for all partitions have been enqueued but not yet replicated.
| Constructor and Description |
|---|
WanAntiEntropyEventPublishOperation() |
WanAntiEntropyEventPublishOperation(String wanReplicationName,
String targetGroupName,
WanAntiEntropyEvent event) |
| Modifier and Type | Method and Description |
|---|---|
int |
getFactoryId() |
int |
getId() |
protected void |
readInternal(com.hazelcast.nio.ObjectDataInput in) |
boolean |
returnsResponse() |
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, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeDatapublic WanAntiEntropyEventPublishOperation()
public WanAntiEntropyEventPublishOperation(String wanReplicationName, String targetGroupName, WanAntiEntropyEvent event)
public void run()
throws Exception
run in class com.hazelcast.spi.OperationExceptionprotected 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.OperationIOExceptionpublic int getFactoryId()
getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializablepublic int getId()
getId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializablepublic boolean returnsResponse()
returnsResponse in class com.hazelcast.spi.OperationCopyright © 2022 Hazelcast, Inc.. All Rights Reserved.