@ManagedObject public class RoundRobinConnectionPool extends AbstractConnectionPool implements ConnectionPool.Multiplexable
ConnectionPool.Factory, ConnectionPool.Multiplexable
Constructor and Description |
---|
RoundRobinConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
RoundRobinConnectionPool(Destination destination,
int maxConnections,
Callback requester,
int maxMultiplex) |
Modifier and Type | Method and Description |
---|---|
protected Connection |
activate() |
void |
dump(java.lang.Appendable out,
java.lang.String indent)
Dump this object (and children) into an Appendable using the provided indent after any new lines.
|
int |
getMaxMultiplex() |
boolean |
isActive(Connection connection) |
protected void |
onCreated(Connection connection) |
boolean |
release(Connection connection)
Returns the given connection, previously obtained via
ConnectionPool.acquire() ,
back to this ConnectionPool. |
boolean |
remove(Connection connection)
Removes the given connection from this ConnectionPool.
|
void |
setMaxMultiplex(int maxMultiplex) |
java.lang.String |
toString() |
acquire, acquired, active, close, close, dump, getConnectionCount, getMaxConnectionCount, getPendingCount, idle, isClosed, isEmpty, proceed, released, removed, tryCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dump, dumpObject, dumpObjects, dumpSelf
public RoundRobinConnectionPool(Destination destination, int maxConnections, Callback requester)
public RoundRobinConnectionPool(Destination destination, int maxConnections, Callback requester, int maxMultiplex)
public int getMaxMultiplex()
getMaxMultiplex
in interface ConnectionPool.Multiplexable
public void setMaxMultiplex(int maxMultiplex)
setMaxMultiplex
in interface ConnectionPool.Multiplexable
maxMultiplex
- the max number of requests multiplexable on a single connectionprotected void onCreated(Connection connection)
onCreated
in class AbstractConnectionPool
protected Connection activate()
activate
in class AbstractConnectionPool
public boolean isActive(Connection connection)
isActive
in interface ConnectionPool
connection
- the connection to testpublic boolean release(Connection connection)
ConnectionPool
Returns the given connection, previously obtained via ConnectionPool.acquire()
,
back to this ConnectionPool.
release
in interface ConnectionPool
connection
- the connection to releasepublic boolean remove(Connection connection)
ConnectionPool
Removes the given connection from this ConnectionPool.
remove
in interface ConnectionPool
connection
- the connection to removepublic void dump(java.lang.Appendable out, java.lang.String indent) throws java.io.IOException
Dumpable
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 1995–2023 Webtide. All rights reserved.