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
BrokerExceptionpublic BrokerConnectionPool(java.lang.String host,
int port,
java.lang.String accessCode,
java.lang.String verifyCode,
int minPoolSize,
long reapDelay,
long inactiveTimeout)
throws BrokerException
BrokerExceptionpublic void reapConnections()
throws BrokerException
BrokerExceptionpublic void closeConnections()
throws BrokerException
BrokerExceptionpublic BrokerConnection getConnection() throws BrokerException
BrokerExceptionpublic void returnConnection(BrokerConnection conn)
public int getPoolSize()
public int getNumLeasedConnections()
public void terminate()
throws BrokerException
BrokerException