org.apache.nifi.cluster.integration

Class ClusterUtils

java.lang.Object

org.apache.nifi.cluster.integration.ClusterUtils

public class ClusterUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ClusterUtils()

Method Summary

Modifier and Type	Method and Description
static void	waitUntilConditionMet(long time, java.util.concurrent.TimeUnit timeUnit, java.util.function.BooleanSupplier test)
static void	waitUntilConditionMet(long time, java.util.concurrent.TimeUnit timeUnit, java.util.function.BooleanSupplier test, java.util.function.Supplier<java.lang.String> errorMessageSupplier)
static <T> T	waitUntilNonNull(long time, java.util.concurrent.TimeUnit timeUnit, java.util.function.Supplier<T> test)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterUtils

public ClusterUtils()

Method Detail

waitUntilConditionMet

public static void waitUntilConditionMet(long time,
                                         java.util.concurrent.TimeUnit timeUnit,
                                         java.util.function.BooleanSupplier test)

waitUntilConditionMet

public static void waitUntilConditionMet(long time,
                                         java.util.concurrent.TimeUnit timeUnit,
                                         java.util.function.BooleanSupplier test,
                                         java.util.function.Supplier<java.lang.String> errorMessageSupplier)

waitUntilNonNull

public static <T> T waitUntilNonNull(long time,
                                     java.util.concurrent.TimeUnit timeUnit,
                                     java.util.function.Supplier<T> test)