public class BrokerConnectionPool
extends java.lang.Object
Constructor and Description |
---|
BrokerConnectionPool(java.lang.String host,
int port,
int minPoolSize,
long reapDelay,
long inactiveTimeout) |
BrokerConnectionPool(java.lang.String host,
int port,
java.lang.String accessCode,
java.lang.String verifyCode,
int minPoolSize,
long reapDelay,
long inactiveTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
closeConnections() |
BrokerConnection |
getConnection() |
int |
getNumLeasedConnections() |
int |
getPoolSize() |
void |
reapConnections() |
void |
returnConnection(BrokerConnection conn) |
void |
terminate() |
public BrokerConnectionPool(java.lang.String host, int port, int minPoolSize, long reapDelay, long inactiveTimeout) throws BrokerException
BrokerException
public BrokerConnectionPool(java.lang.String host, int port, java.lang.String accessCode, java.lang.String verifyCode, int minPoolSize, long reapDelay, long inactiveTimeout) throws BrokerException
BrokerException
public void reapConnections() throws BrokerException
BrokerException
public void closeConnections() throws BrokerException
BrokerException
public BrokerConnection getConnection() throws BrokerException
BrokerException
public void returnConnection(BrokerConnection conn)
public int getPoolSize()
public int getNumLeasedConnections()
public void terminate() throws BrokerException
BrokerException