AddCacheConfigOperation
, which is used in conjunction with
InvocationUtil.invokeOnStableClusterSerial(NodeEngine,
com.hazelcast.util.function.Supplier, int)
to reliably broadcast the CacheConfig
to all members of the cluster.@Deprecated public class CacheCreateConfigOperation extends AbstractNamedOperation implements IdentifiedDataSerializable
This configuration is created using the following algorithm;
CacheCreateConfigOperation
operation to the calculated partition which will force all
clusters to be single threaded.ICacheService.putCacheConfigIfAbsent(com.hazelcast.config.CacheConfig)
is called.
This operation's purpose is to pass the required parameters into
ICacheService.putCacheConfigIfAbsent(com.hazelcast.config.CacheConfig)
.
createAlsoOnOthers
is true
and there are at least one
remote members on which the new CacheConfig
needs to be created. When this operation returns null
with createAlsoOnOthers == true
, it is impossible to tell whether it is because the CacheConfig
was not already registered
or due to sending out the operation to other remote members.name
GENERIC_PARTITION_ID
Constructor and Description |
---|
CacheCreateConfigOperation()
Deprecated.
|
CacheCreateConfigOperation(CacheConfig config,
boolean createAlsoOnOthers)
Deprecated.
|
CacheCreateConfigOperation(CacheConfig config,
boolean createAlsoOnOthers,
boolean ignoreLocal)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
int |
getFactoryId()
Deprecated.
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Deprecated.
Returns type identifier for this class.
|
Object |
getResponse()
Deprecated.
Called if and only if
Operation.returnsResponse() returned true , shortly after Operation.run()
returns. |
String |
getServiceName()
Deprecated.
|
void |
onExecutionFailure(Throwable e)
Deprecated.
Called when an Exception/Error is thrown during operation execution.
|
protected void |
readInternal(ObjectDataInput in)
Deprecated.
|
boolean |
returnsResponse()
Deprecated.
Method is intended to be subclassed.
|
void |
run()
Deprecated.
|
protected void |
writeInternal(ObjectDataOutput out)
Deprecated.
|
getName, toString
afterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onInvocationException, onSetCallId, readData, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
readData, writeData
public CacheCreateConfigOperation()
public CacheCreateConfigOperation(CacheConfig config, boolean createAlsoOnOthers)
public CacheCreateConfigOperation(CacheConfig config, boolean createAlsoOnOthers, boolean ignoreLocal)
public String getServiceName()
getServiceName
in class Operation
public void run() throws Exception
public void onExecutionFailure(Throwable e)
Operation
onExecutionFailure
in class Operation
e
- Exception/Error thrown during operation executionpublic Object getResponse()
Operation
Operation.returnsResponse()
returned true
, shortly after Operation.run()
returns.getResponse
in class Operation
public boolean returnsResponse()
Operation
true
, Operation.getResponse()
will be
called right after Operation.run()
method. If it returns false
, Operation.sendResponse(Object)
must be called later to finish the operation.
In other words, true
is for synchronous operation and false
is for asynchronous one.
Default implementation is synchronous operation (true
).
returnsResponse
in class Operation
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class AbstractNamedOperation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class AbstractNamedOperation
IOException
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.