public class PooledConnectionFactory extends Object implements javax.jms.ConnectionFactory, Service
Constructor and Description |
---|
PooledConnectionFactory() |
PooledConnectionFactory(ActiveMQConnectionFactory connectionFactory) |
PooledConnectionFactory(String brokerURL) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Connection |
createConnection() |
protected ActiveMQConnection |
createConnection(ConnectionKey key) |
javax.jms.Connection |
createConnection(String userName,
String password) |
protected ConnectionPool |
createConnectionPool(ActiveMQConnection connection) |
protected org.apache.commons.pool.ObjectPoolFactory |
createPoolFactory()
Creates an ObjectPoolFactory.
|
javax.jms.ConnectionFactory |
getConnectionFactory() |
long |
getExpiryTimeout() |
int |
getIdleTimeout() |
int |
getMaxConnections() |
int |
getMaximumActive() |
org.apache.commons.pool.ObjectPoolFactory |
getPoolFactory() |
void |
setBlockIfSessionPoolIsFull(boolean block)
Controls the behavior of the internal session pool.
|
void |
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory) |
void |
setExpiryTimeout(long expiryTimeout)
allow connections to expire, irrespective of load or idle time.
|
void |
setIdleTimeout(int idleTimeout) |
void |
setMaxConnections(int maxConnections) |
void |
setMaximumActive(int maximumActive)
Sets the maximum number of active sessions per connection
|
void |
setPoolFactory(org.apache.commons.pool.ObjectPoolFactory poolFactory)
Sets the object pool factory used to create individual session pools for
each connection
|
void |
start() |
void |
stop() |
public PooledConnectionFactory()
public PooledConnectionFactory(String brokerURL)
public PooledConnectionFactory(ActiveMQConnectionFactory connectionFactory)
public javax.jms.ConnectionFactory getConnectionFactory()
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
public javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
public javax.jms.Connection createConnection(String userName, String password) throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
protected ConnectionPool createConnectionPool(ActiveMQConnection connection)
protected ActiveMQConnection createConnection(ConnectionKey key) throws javax.jms.JMSException
javax.jms.JMSException
public void start()
public org.apache.commons.pool.ObjectPoolFactory getPoolFactory()
public void setPoolFactory(org.apache.commons.pool.ObjectPoolFactory poolFactory)
public int getMaximumActive()
public void setMaximumActive(int maximumActive)
public void setBlockIfSessionPoolIsFull(boolean block)
block
- - if true, the call to getSession() blocks if the pool is full
until a session object is available. defaults to true.public int getMaxConnections()
public void setMaxConnections(int maxConnections)
maxConnections
- the maxConnections to setprotected org.apache.commons.pool.ObjectPoolFactory createPoolFactory()
public int getIdleTimeout()
public void setIdleTimeout(int idleTimeout)
public void setExpiryTimeout(long expiryTimeout)
expiryTimeout
- non zero in millisecondspublic long getExpiryTimeout()
Copyright © 2005–2014. All rights reserved.