@ManagedObject(value="The connection pool") public class DuplexConnectionPool extends Object implements Closeable, Dumpable, Sweeper.Sweepable
Constructor and Description |
---|
DuplexConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
Modifier and Type | Method and Description |
---|---|
Connection |
acquire() |
protected void |
acquired(Connection connection) |
void |
close() |
String |
dump() |
void |
dump(Appendable out,
String indent) |
int |
getActiveConnectionCount() |
Queue<Connection> |
getActiveConnections() |
int |
getConnectionCount() |
int |
getIdleConnectionCount() |
Queue<Connection> |
getIdleConnections() |
protected boolean |
idle(Connection connection,
boolean idle) |
protected void |
idleCreated(Connection connection) |
boolean |
isActive(Connection connection) |
boolean |
isEmpty() |
boolean |
isIdle(Connection connection) |
protected void |
lock() |
protected boolean |
offerIdle(Connection connection) |
protected void |
proceed() |
boolean |
release(Connection connection) |
protected void |
released(Connection connection) |
boolean |
remove(Connection connection) |
protected boolean |
remove(Connection connection,
boolean force) |
boolean |
sweep() |
String |
toString() |
protected void |
unlock() |
public DuplexConnectionPool(Destination destination, int maxConnections, Callback requester)
@ManagedAttribute(value="The number of connections", readonly=true) public int getConnectionCount()
@ManagedAttribute(value="The number of idle connections", readonly=true) public int getIdleConnectionCount()
@ManagedAttribute(value="The number of active connections", readonly=true) public int getActiveConnectionCount()
public Queue<Connection> getIdleConnections()
public Queue<Connection> getActiveConnections()
public Connection acquire()
protected void proceed()
protected void idleCreated(Connection connection)
protected void acquired(Connection connection)
public boolean release(Connection connection)
protected boolean offerIdle(Connection connection)
protected boolean idle(Connection connection, boolean idle)
protected void released(Connection connection)
public boolean remove(Connection connection)
protected boolean remove(Connection connection, boolean force)
public boolean isActive(Connection connection)
public boolean isIdle(Connection connection)
public boolean isEmpty()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public void dump(Appendable out, String indent) throws IOException
dump
in interface Dumpable
IOException
public boolean sweep()
sweep
in interface Sweeper.Sweepable
protected void lock()
protected void unlock()
Copyright © 1995-2016 Webtide. All Rights Reserved.