public class InfinispanClusterProvider extends Object implements ClusterProvider
ClusterProvider.DCNotify
Modifier and Type | Field and Description |
---|---|
static String |
CLUSTER_STARTUP_TIME_KEY |
protected static org.jboss.logging.Logger |
logger |
Constructor and Description |
---|
InfinispanClusterProvider(int clusterStartupTime,
String myAddress,
org.keycloak.cluster.infinispan.CrossDCAwareCacheFactory crossDCAwareCacheFactory,
InfinispanNotificationsManager notificationsManager,
ExecutorService localExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
<T> ExecutionResult<T> |
executeIfNotExecuted(String taskKey,
int taskTimeoutInSeconds,
Callable<T> task) |
Future<Boolean> |
executeIfNotExecutedAsync(String taskKey,
int taskTimeoutInSeconds,
Callable task) |
int |
getClusterStartupTime() |
void |
notify(String taskKey,
ClusterEvent event,
boolean ignoreSender,
ClusterProvider.DCNotify dcNotify) |
void |
registerListener(String taskKey,
ClusterListener task) |
protected static final org.jboss.logging.Logger logger
public static final String CLUSTER_STARTUP_TIME_KEY
public InfinispanClusterProvider(int clusterStartupTime, String myAddress, org.keycloak.cluster.infinispan.CrossDCAwareCacheFactory crossDCAwareCacheFactory, InfinispanNotificationsManager notificationsManager, ExecutorService localExecutor)
public int getClusterStartupTime()
getClusterStartupTime
in interface ClusterProvider
public <T> ExecutionResult<T> executeIfNotExecuted(String taskKey, int taskTimeoutInSeconds, Callable<T> task)
executeIfNotExecuted
in interface ClusterProvider
public Future<Boolean> executeIfNotExecutedAsync(String taskKey, int taskTimeoutInSeconds, Callable task)
executeIfNotExecutedAsync
in interface ClusterProvider
public void registerListener(String taskKey, ClusterListener task)
registerListener
in interface ClusterProvider
public void notify(String taskKey, ClusterEvent event, boolean ignoreSender, ClusterProvider.DCNotify dcNotify)
notify
in interface ClusterProvider
Copyright © 2021 JBoss by Red Hat. All rights reserved.