Class ConnectionValidator
- java.lang.Object
-
- org.mariadb.jdbc.internal.failover.thread.ConnectionValidator
-
public class ConnectionValidator extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private classConnectionValidator.ListenerChecker
-
Field Summary
Fields Modifier and Type Field Description private ConnectionValidator.ListenerCheckercheckerprivate java.util.concurrent.atomic.AtomicLongcurrentScheduledFrequencyprivate java.util.concurrent.ScheduledExecutorServicefixedSizedSchedulerprivate static intMINIMUM_CHECK_DELAY_MILLISprivate java.util.concurrent.ConcurrentLinkedQueue<Listener>queue
-
Constructor Summary
Constructors Constructor Description ConnectionValidator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddListener(Listener listener, long listenerCheckMillis)Add listener to validation list.voidremoveListener(Listener listener)Remove listener to validation list.
-
-
-
Field Detail
-
MINIMUM_CHECK_DELAY_MILLIS
private static final int MINIMUM_CHECK_DELAY_MILLIS
- See Also:
- Constant Field Values
-
fixedSizedScheduler
private final java.util.concurrent.ScheduledExecutorService fixedSizedScheduler
-
queue
private final java.util.concurrent.ConcurrentLinkedQueue<Listener> queue
-
currentScheduledFrequency
private final java.util.concurrent.atomic.AtomicLong currentScheduledFrequency
-
checker
private final ConnectionValidator.ListenerChecker checker
-
-
Method Detail
-
addListener
public void addListener(Listener listener, long listenerCheckMillis)
Add listener to validation list.- Parameters:
listener- listenerlistenerCheckMillis- schedule time
-
removeListener
public void removeListener(Listener listener)
Remove listener to validation list.- Parameters:
listener- listener
-
-