com.hazelcast.internal.util

Class InvocationUtil

java.lang.Object

com.hazelcast.internal.util.InvocationUtil

public final class InvocationUtil
extends Object

Utility methods for invocations.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

invokeOnStableClusterSerial

public static ICompletableFuture<Object> invokeOnStableClusterSerial(NodeEngine nodeEngine,
                                                                     Supplier<? extends Operation> operationSupplier,
                                                                     int maxRetries)

Invoke operation on all cluster members. The invocation is serial: It iterates over all members starting from the oldest member to the youngest one. If there is a cluster membership change while invoking then it will restart invocations on all members. This implies the operation should be idempotent. If there is an exception - other than MemberLeftException or TargetNotMemberException while invoking then the iteration is interrupted and the exception is propagated to the caller.

executeLocallyWithRetry

public static LocalRetryableExecution executeLocallyWithRetry(NodeEngine nodeEngine,
                                                              Operation operation)

Constructs a local execution with retry logic. The operation must not have an OperationResponseHandler, it must return a response and it must not validate the target.

Returns:

the local execution

Throws:

IllegalArgumentException - if the operation has a response handler set, if it does not return a response or if it validates the operation target

See Also:

Operation.returnsResponse(), Operation.getOperationResponseHandler(), Operation.validatesTarget()