@ThreadSafe class DefaultServerMonitor extends java.lang.Object implements ServerMonitor
Modifier and Type | Class and Description |
---|---|
(package private) class |
DefaultServerMonitor.ServerMonitorRunnable |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.locks.Condition |
condition |
private ConnectionPool |
connectionPool |
private InternalConnectionFactory |
internalConnectionFactory |
private boolean |
isClosed |
private java.util.concurrent.locks.Lock |
lock |
private static Logger |
LOGGER |
private DefaultServerMonitor.ServerMonitorRunnable |
monitor |
private java.lang.Thread |
monitorThread |
private ServerId |
serverId |
private ServerMonitorListener |
serverMonitorListener |
private ServerSettings |
serverSettings |
private ChangeListener<ServerDescription> |
serverStateListener |
Constructor and Description |
---|
DefaultServerMonitor(ServerId serverId,
ServerSettings serverSettings,
ChangeListener<ServerDescription> serverStateListener,
InternalConnectionFactory internalConnectionFactory,
ConnectionPool connectionPool) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
connect() |
(package private) static boolean |
shouldLogStageChange(ServerDescription previous,
ServerDescription current) |
void |
start() |
private static final Logger LOGGER
private final ServerId serverId
private final ServerMonitorListener serverMonitorListener
private final ChangeListener<ServerDescription> serverStateListener
private final InternalConnectionFactory internalConnectionFactory
private final ConnectionPool connectionPool
private final ServerSettings serverSettings
private final DefaultServerMonitor.ServerMonitorRunnable monitor
private final java.lang.Thread monitorThread
private final java.util.concurrent.locks.Lock lock
private final java.util.concurrent.locks.Condition condition
private volatile boolean isClosed
DefaultServerMonitor(ServerId serverId, ServerSettings serverSettings, ChangeListener<ServerDescription> serverStateListener, InternalConnectionFactory internalConnectionFactory, ConnectionPool connectionPool)
public void start()
start
in interface ServerMonitor
public void connect()
connect
in interface ServerMonitor
public void close()
close
in interface ServerMonitor
static boolean shouldLogStageChange(ServerDescription previous, ServerDescription current)