org.infinispan.manager.impl

Class ClusterExecutors

java.lang.Object

org.infinispan.manager.impl.ClusterExecutors

public class ClusterExecutors
extends Object

Static factory methods to construct a ClusterExecutor

Since:

9.0

Author:

wburns

Method Summary

Modifier and Type	Method and Description
static ClusterExecutor	allSubmissionExecutor(Predicate<? super Address> predicate, EmbeddedCacheManager manager, Transport transport, long time, TimeUnit unit, Executor localExecutor, ScheduledExecutorService timeoutExecutor)
static ClusterExecutor	singleNodeSubmissionExecutor(Predicate<? super Address> predicate, EmbeddedCacheManager manager, Transport transport, long time, TimeUnit unit, Executor localExecutor, ScheduledExecutorService timeoutExecutor, int failOverCount)

Methods inherited from class java.lang.Object

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

Method Detail

allSubmissionExecutor

public static ClusterExecutor allSubmissionExecutor(Predicate<? super Address> predicate,
                                                    EmbeddedCacheManager manager,
                                                    Transport transport,
                                                    long time,
                                                    TimeUnit unit,
                                                    Executor localExecutor,
                                                    ScheduledExecutorService timeoutExecutor)

singleNodeSubmissionExecutor

public static ClusterExecutor singleNodeSubmissionExecutor(Predicate<? super Address> predicate,
                                                           EmbeddedCacheManager manager,
                                                           Transport transport,
                                                           long time,
                                                           TimeUnit unit,
                                                           Executor localExecutor,
                                                           ScheduledExecutorService timeoutExecutor,
                                                           int failOverCount)