public class LeakTrackingConnectionPool extends DuplexConnectionPool
ConnectionPool.Factory, ConnectionPool.Multiplexable
Modifier and Type | Field and Description |
---|---|
private LeakDetector<Connection> |
leakDetector |
private static Logger |
LOG |
Constructor and Description |
---|
LeakTrackingConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
Modifier and Type | Method and Description |
---|---|
protected void |
acquired(Connection connection) |
void |
close()
Closes this ConnectionPool.
|
protected void |
leaked(LeakDetector.LeakInfo leakInfo) |
protected void |
released(Connection connection) |
private void |
start() |
private void |
stop() |
activate, deactivate, dump, dump, getActiveConnectionCount, getActiveConnections, getIdleConnectionCount, getIdleConnections, isActive, lock, onCreated, release, remove, remove, sweep, toString, unlock
acquire, active, close, dump, getConnectionCount, getMaxConnectionCount, getPendingCount, idle, isClosed, isEmpty, proceed, removed, tryCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dump, dumpContainer, dumpIterable, dumpMapEntries, dumpObject, dumpObjects, dumpSelf, named
private static final Logger LOG
private final LeakDetector<Connection> leakDetector
public LeakTrackingConnectionPool(Destination destination, int maxConnections, Callback requester)
private void start()
public void close()
ConnectionPool
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface ConnectionPool
close
in class DuplexConnectionPool
ConnectionPool.isClosed()
private void stop()
protected void acquired(Connection connection)
acquired
in class AbstractConnectionPool
protected void released(Connection connection)
released
in class AbstractConnectionPool
protected void leaked(LeakDetector.LeakInfo leakInfo)