org.apache.activemq.pool
Class XaPooledConnectionFactory

java.lang.Object
  org.apache.activemq.pool.PooledConnectionFactory
      org.apache.activemq.pool.XaPooledConnectionFactory

All Implemented Interfaces:

javax.jms.ConnectionFactory, Service

Direct Known Subclasses:

JcaPooledConnectionFactory

public class XaPooledConnectionFactory
extends PooledConnectionFactory

A pooled connection factory that automatically enlists sessions in the current active XA transaction if any.

Constructor Summary

XaPooledConnectionFactory()

XaPooledConnectionFactory(ActiveMQConnectionFactory connectionFactory)

XaPooledConnectionFactory(java.lang.String brokerURL)

Method Summary

protected ConnectionPool	createConnectionPool(ActiveMQConnection connection)
javax.transaction.TransactionManager	getTransactionManager()
void	setTransactionManager(javax.transaction.TransactionManager transactionManager)

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

createConnection, createConnection, createConnection, createPoolFactory, getConnectionFactory, getExpiryTimeout, getIdleTimeout, getMaxConnections, getMaximumActive, getPoolFactory, setBlockIfSessionPoolIsFull, setConnectionFactory, setExpiryTimeout, setIdleTimeout, setMaxConnections, setMaximumActive, setPoolFactory, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

XaPooledConnectionFactory

public XaPooledConnectionFactory()

XaPooledConnectionFactory

public XaPooledConnectionFactory(ActiveMQConnectionFactory connectionFactory)

XaPooledConnectionFactory

public XaPooledConnectionFactory(java.lang.String brokerURL)

Method Detail

getTransactionManager

public javax.transaction.TransactionManager getTransactionManager()

setTransactionManager

public void setTransactionManager(javax.transaction.TransactionManager transactionManager)

createConnectionPool

protected ConnectionPool createConnectionPool(ActiveMQConnection connection)

Overrides:

createConnectionPool in class PooledConnectionFactory