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 class
ConnectionValidator.ListenerChecker
-
Field Summary
Fields Modifier and Type Field Description private ConnectionValidator.ListenerChecker
checker
private java.util.concurrent.atomic.AtomicLong
currentScheduledFrequency
private static java.util.concurrent.ScheduledExecutorService
fixedSizedScheduler
private static int
MINIMUM_CHECK_DELAY_MILLIS
private 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 void
addListener(Listener listener, long listenerCheckMillis)
Add listener to validation list.void
removeListener(Listener listener)
Remove listener to validation list.
-
-
-
Field Detail
-
fixedSizedScheduler
private static final java.util.concurrent.ScheduledExecutorService fixedSizedScheduler
-
MINIMUM_CHECK_DELAY_MILLIS
private static final int MINIMUM_CHECK_DELAY_MILLIS
- See Also:
- Constant Field Values
-
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
-
-