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:

java.io.Serializable, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.naming.Referenceable, javax.naming.spi.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 and Description
static java.lang.String	POOL_PROPS_PREFIX

Fields inherited from class org.apache.activemq.jms.pool.PooledConnectionFactory

stopped

Constructor Summary

Constructors

Constructor and Description
XaPooledConnectionFactory()
XaPooledConnectionFactory(ActiveMQXAConnectionFactory connectionFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	buildFromProperties(java.util.Properties props)
protected ConnectionPool	createConnectionPool(javax.jms.Connection connection) Delegate that creates each instance of an ConnectionPool object.
java.lang.String	getBrokerUrl()
java.util.Properties	getProperties() Get the properties from this instance for storing in JNDI
javax.naming.Reference	getReference()
protected void	populateProperties(java.util.Properties props)
void	setBrokerUrl(java.lang.String url)
void	setProperties(java.util.Properties properties) set the properties for this instance as retrieved from JNDI

Methods inherited from class org.apache.activemq.jms.pool.XaPooledConnectionFactory

createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getObjectInstance, getTmJndiName, getTransactionManager, isTmFromJndi, setTmFromJndi, setTmJndiName, setTransactionManager

Methods inherited from class org.apache.activemq.jms.pool.PooledConnectionFactory

clear, createConnection, createConnection, createConnection, getBlockIfSessionPoolIsFullTimeout, getConnectionFactory, getConnectionsPool, getExpiryTimeout, getIdleTimeout, getMaxConnections, getMaximumActiveSessionPerConnection, getNumConnections, getTimeBetweenExpirationCheckMillis, initConnectionsPool, isBlockIfSessionPoolIsFull, isCreateConnectionOnStartup, isUseAnonymousProducers, newPooledConnection, setBlockIfSessionPoolIsFull, setBlockIfSessionPoolIsFullTimeout, setConnectionFactory, setCreateConnectionOnStartup, setExpiryTimeout, setIdleTimeout, setMaxConnections, setMaximumActiveSessionPerConnection, setTimeBetweenExpirationCheckMillis, setUseAnonymousProducers, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.Service

start, stop

Methods inherited from interface javax.jms.ConnectionFactory

createConnection, createConnection

Field Detail

POOL_PROPS_PREFIX

public static final java.lang.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(javax.jms.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 class XaPooledConnectionFactory

Returns:

instance of a new ConnectionPool.

buildFromProperties

protected void buildFromProperties(java.util.Properties props)

populateProperties

protected void populateProperties(java.util.Properties props)

setProperties

public void setProperties(java.util.Properties properties)

Description copied from interface: JNDIStorableInterface

set the properties for this instance as retrieved from JNDI

Specified by:

setProperties in interface JNDIStorableInterface

getProperties

public java.util.Properties getProperties()

Description copied from interface: JNDIStorableInterface

Get the properties from this instance for storing in JNDI

Specified by:

getProperties in interface JNDIStorableInterface

Returns:

getReference

public javax.naming.Reference getReference()
                                    throws javax.naming.NamingException

Specified by:

getReference in interface javax.naming.Referenceable

Throws:

javax.naming.NamingException

setBrokerUrl

public void setBrokerUrl(java.lang.String url)

getBrokerUrl

public java.lang.String getBrokerUrl()