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 ICompletableFuture<Object>	invokeOnStableClusterSerial(NodeEngine nodeEngine, Supplier<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<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.