Package org.apache.activemq.pool
Class XaPooledConnectionFactory
- java.lang.Object
-
- org.apache.activemq.jms.pool.PooledConnectionFactory
-
- org.apache.activemq.jms.pool.XaPooledConnectionFactory
-
- org.apache.activemq.pool.XaPooledConnectionFactory
-
- All Implemented Interfaces:
Serializable
,ConnectionFactory
,QueueConnectionFactory
,TopicConnectionFactory
,Referenceable
,ObjectFactory
,JNDIStorableInterface
,Service
- Direct Known Subclasses:
JcaPooledConnectionFactory
public class XaPooledConnectionFactory extends XaPooledConnectionFactory implements JNDIStorableInterface, Service
Add Service and Referenceable and TransportListener to @link{org.apache.activemq.jms.pool.XaPooledConnectionFactory}- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static String
POOL_PROPS_PREFIX
-
Fields inherited from class org.apache.activemq.jms.pool.PooledConnectionFactory
connectionFactory, stopped
-
-
Constructor Summary
Constructors Constructor Description XaPooledConnectionFactory()
XaPooledConnectionFactory(ActiveMQXAConnectionFactory connectionFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
buildFromProperties(Properties props)
protected ConnectionPool
createConnectionPool(Connection connection)
Delegate that creates each instance of an ConnectionPool object.String
getBrokerUrl()
Properties
getProperties()
Get the properties from this instance for storing in JNDIReference
getReference()
protected void
populateProperties(Properties props)
Called by any superclass that implements a JNDIReferencable or similar that needs to collect the properties of this class for storage etc.void
setBrokerUrl(String url)
void
setProperties(Properties properties)
set the properties for this instance as retrieved from JNDI-
Methods inherited from class org.apache.activemq.jms.pool.XaPooledConnectionFactory
createConnection, getObjectInstance, getTmJndiName, getTransactionManager, isTmFromJndi, setConnectionFactory, setTmFromJndi, setTmJndiName, setTransactionManager
-
Methods inherited from class org.apache.activemq.jms.pool.PooledConnectionFactory
clear, createConnection, createConnection, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getBlockIfSessionPoolIsFullTimeout, getConnectionFactory, getConnectionsPool, getConnectionTimeout, getExpiryTimeout, getIdleTimeout, getMaxConnections, getMaximumActiveSessionPerConnection, getNumConnections, getTimeBetweenExpirationCheckMillis, initConnectionsPool, isBlockIfSessionPoolIsFull, isCreateConnectionOnStartup, isReconnectOnException, isUseAnonymousProducers, newPooledConnection, setBlockIfSessionPoolIsFull, setBlockIfSessionPoolIsFullTimeout, setConnectionTimeout, setCreateConnectionOnStartup, setExpiryTimeout, setIdleTimeout, setMaxConnections, setMaximumActiveSessionPerConnection, setReconnectOnException, setTimeBetweenExpirationCheckMillis, setUseAnonymousProducers, start, stop
-
-
-
-
Field Detail
-
POOL_PROPS_PREFIX
public static final String POOL_PROPS_PREFIX
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
XaPooledConnectionFactory
public XaPooledConnectionFactory()
-
XaPooledConnectionFactory
public XaPooledConnectionFactory(ActiveMQXAConnectionFactory connectionFactory)
-
-
Method Detail
-
createConnectionPool
protected ConnectionPool createConnectionPool(Connection connection)
Description copied from class:PooledConnectionFactory
Delegate that creates each instance of an ConnectionPool object. Subclasses can override this method to customize the type of connection pool returned.- Overrides:
createConnectionPool
in classXaPooledConnectionFactory
- Returns:
- instance of a new ConnectionPool.
-
buildFromProperties
protected void buildFromProperties(Properties props)
-
populateProperties
protected void populateProperties(Properties props)
Description copied from class:PooledConnectionFactory
Called by any superclass that implements a JNDIReferencable or similar that needs to collect the properties of this class for storage etc. This method should be updated any time there is a new property added.- Overrides:
populateProperties
in classPooledConnectionFactory
- Parameters:
props
- a properties object that should be filled in with this objects property values.
-
setProperties
public void setProperties(Properties properties)
Description copied from interface:JNDIStorableInterface
set the properties for this instance as retrieved from JNDI- Specified by:
setProperties
in interfaceJNDIStorableInterface
-
getProperties
public Properties getProperties()
Description copied from interface:JNDIStorableInterface
Get the properties from this instance for storing in JNDI- Specified by:
getProperties
in interfaceJNDIStorableInterface
- Returns:
- the properties that should be stored in JNDI
-
getReference
public Reference getReference() throws NamingException
- Specified by:
getReference
in interfaceReferenceable
- Throws:
NamingException
-
setBrokerUrl
public void setBrokerUrl(String url)
-
getBrokerUrl
public String getBrokerUrl()
-
-