public interface ClusterProvider extends Provider
Modifier and Type | Method and Description |
---|---|
<T> ExecutionResult<T> |
executeIfNotExecuted(String taskKey,
int taskTimeoutInSeconds,
Callable<T> task)
Execute given task just if it's not already in progress (either on this or any other cluster node).
|
int |
getClusterStartupTime()
Same value for all cluster nodes.
|
void |
notify(String taskKey,
ClusterEvent event)
Notify registered listeners on all cluster nodes
|
void |
registerListener(String taskKey,
ClusterListener task)
Register task (listener) under given key.
|
int getClusterStartupTime()
<T> ExecutionResult<T> executeIfNotExecuted(String taskKey, int taskTimeoutInSeconds, Callable<T> task)
T
- taskKey
- taskTimeoutInSeconds
- timeout for given task. If there is existing task in progress for longer time, it's considered outdated so we will start our task.task
- void registerListener(String taskKey, ClusterListener task)
taskKey
- task
- void notify(String taskKey, ClusterEvent event)
taskKey
- event
- Copyright © 2016 JBoss by Red Hat. All rights reserved.