public final class InvocationUtil extends Object
Modifier and Type | Method and Description |
---|---|
static LocalRetryableExecution |
executeLocallyWithRetry(NodeEngine nodeEngine,
Operation operation)
Constructs a local execution with retry logic.
|
static ICompletableFuture<Object> |
invokeOnStableClusterSerial(NodeEngine nodeEngine,
Supplier<? extends Operation> operationSupplier,
int maxRetries)
Invoke operation on all cluster members.
|
public static ICompletableFuture<Object> invokeOnStableClusterSerial(NodeEngine nodeEngine, Supplier<? extends Operation> operationSupplier, int maxRetries)
MemberLeftException
or
TargetNotMemberException
while invoking then the iteration
is interrupted and the exception is propagated to the caller.public static LocalRetryableExecution executeLocallyWithRetry(NodeEngine nodeEngine, Operation operation)
OperationResponseHandler
, it must return a response
and it must not validate the target.IllegalArgumentException
- if the operation has a response handler
set, if it does not return a response
or if it validates the operation targetOperation.returnsResponse()
,
Operation.getOperationResponseHandler()
,
Operation.validatesTarget()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.