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, unscheduleTask
private 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