Package org.mariadb.jdbc.internal.failover.thread

Class ConnectionValidator

java.lang.Object

org.mariadb.jdbc.internal.failover.thread.ConnectionValidator

public class ConnectionValidator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ConnectionValidator.ListenerChecker

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionValidator.ListenerChecker	checker
private final AtomicLong	currentScheduledFrequency
private static final ScheduledExecutorService	fixedSizedScheduler
private static final int	MINIMUM_CHECK_DELAY_MILLIS
private final ConcurrentLinkedQueue<Listener>	queue

Constructor Summary

Constructors

Constructor	Description
ConnectionValidator()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

fixedSizedScheduler

private static final ScheduledExecutorService fixedSizedScheduler

MINIMUM_CHECK_DELAY_MILLIS

private static final int MINIMUM_CHECK_DELAY_MILLIS

See Also:

• Constant Field Values

queue

private final ConcurrentLinkedQueue<Listener> queue

currentScheduledFrequency

private final AtomicLong currentScheduledFrequency

checker

private final ConnectionValidator.ListenerChecker checker

Constructor Details

ConnectionValidator

public ConnectionValidator()

Method Details

addListener

public void addListener(Listener listener,
 long listenerCheckMillis)

Add listener to validation list.

Parameters:

listener - listener

listenerCheckMillis - schedule time

removeListener

public void removeListener(Listener listener)

Remove listener to validation list.

Parameters:

listener - listener