public class FailoverLoop extends TerminableRunnable
| Modifier and Type | Field and Description |
|---|---|
private static java.util.concurrent.ConcurrentLinkedQueue<Listener> |
queue |
| Constructor and Description |
|---|
FailoverLoop(java.util.concurrent.ScheduledExecutorService scheduler) |
| Modifier and Type | Method and Description |
|---|---|
static void |
addListener(Listener listener) |
protected void |
doRun() |
static void |
removeListener(Listener listener) |
blockTillTerminated, isUnschedule, run, unscheduleTaskprivate static final java.util.concurrent.ConcurrentLinkedQueue<Listener> queue
public FailoverLoop(java.util.concurrent.ScheduledExecutorService scheduler)
public static void addListener(Listener listener)
public static void removeListener(Listener listener)
protected void doRun()
doRun in class TerminableRunnable