public class PooledConnectionFactory extends org.apache.activemq.jms.pool.PooledConnectionFactory implements JNDIStorableInterface, Service
Modifier and Type | Field and Description |
---|---|
static String |
POOL_PROPS_PREFIX |
connectionFactory, stopped
Constructor and Description |
---|
PooledConnectionFactory() |
PooledConnectionFactory(ActiveMQConnectionFactory activeMQConnectionFactory) |
PooledConnectionFactory(String brokerURL) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildFromProperties(Properties props) |
protected org.apache.activemq.jms.pool.ConnectionPool |
createConnectionPool(Connection connection) |
Properties |
getProperties() |
Reference |
getReference() |
protected Connection |
newPooledConnection(org.apache.activemq.jms.pool.ConnectionPool connection) |
protected void |
populateProperties(Properties props) |
void |
setProperties(Properties properties) |
clear, createConnection, createConnection, createConnection, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getBlockIfSessionPoolIsFullTimeout, getConnectionFactory, getConnectionsPool, getExpiryTimeout, getIdleTimeout, getMaxConnections, getMaximumActiveSessionPerConnection, getNumConnections, getTimeBetweenExpirationCheckMillis, initConnectionsPool, isBlockIfSessionPoolIsFull, isCreateConnectionOnStartup, isReconnectOnException, isUseAnonymousProducers, setBlockIfSessionPoolIsFull, setBlockIfSessionPoolIsFullTimeout, setConnectionFactory, setCreateConnectionOnStartup, setExpiryTimeout, setIdleTimeout, setMaxConnections, setMaximumActiveSessionPerConnection, setReconnectOnException, setTimeBetweenExpirationCheckMillis, setUseAnonymousProducers, start, stop
public static final String POOL_PROPS_PREFIX
public PooledConnectionFactory()
public PooledConnectionFactory(ActiveMQConnectionFactory activeMQConnectionFactory)
public PooledConnectionFactory(String brokerURL)
protected void buildFromProperties(Properties props)
protected void populateProperties(Properties props)
populateProperties
in class org.apache.activemq.jms.pool.PooledConnectionFactory
public void setProperties(Properties properties)
setProperties
in interface JNDIStorableInterface
public Properties getProperties()
getProperties
in interface JNDIStorableInterface
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
protected Connection newPooledConnection(org.apache.activemq.jms.pool.ConnectionPool connection)
newPooledConnection
in class org.apache.activemq.jms.pool.PooledConnectionFactory
protected org.apache.activemq.jms.pool.ConnectionPool createConnectionPool(Connection connection)
createConnectionPool
in class org.apache.activemq.jms.pool.PooledConnectionFactory
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.