public class ChangeWanStateOperation extends AbstractLocalOperation
wanReplicationName and wanPublisherId.GENERIC_PARTITION_ID| Constructor and Description |
|---|
ChangeWanStateOperation(String wanReplicationName,
String wanPublisherId,
WanPublisherState state) |
| Modifier and Type | Method and Description |
|---|---|
void |
run()
Runs the operation.
|
getClassId, getFactoryId, readInternal, writeInternalafterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getClientCallId, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getServiceName, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setClientCallId, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitreadData, writeDatapublic ChangeWanStateOperation(String wanReplicationName, String wanPublisherId, WanPublisherState state)
public void run()
throws Exception
OperationOperation.run() or Operation.call() method should be implemented; not both.
Runs after wait-support, supposed to do actual operationrun in class OperationExceptionOperation.call()Copyright © 2019 Hazelcast, Inc.. All rights reserved.