org.fusesource.jms.pool

Class XaPooledConnectionFactory

java.lang.Object

org.fusesource.jms.pool.PooledConnectionFactory

org.fusesource.jms.pool.XaPooledConnectionFactory

All Implemented Interfaces:

javax.jms.ConnectionFactory

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

Constructors

Constructor and Description
XaPooledConnectionFactory()

Method Summary

Methods

Modifier and Type	Method and Description
protected ConnectionPool	createConnectionPool(javax.jms.Connection connection)
javax.transaction.TransactionManager	getTransactionManager()
javax.jms.XAConnectionFactory	getXaConnectionFactory()
void	setTransactionManager(javax.transaction.TransactionManager transactionManager)
void	setXaConnectionFactory(javax.jms.XAConnectionFactory xaConnectionFactory)

Methods inherited from class org.fusesource.jms.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()

Method Detail

getXaConnectionFactory

public javax.jms.XAConnectionFactory getXaConnectionFactory()

setXaConnectionFactory

public void setXaConnectionFactory(javax.jms.XAConnectionFactory xaConnectionFactory)

getTransactionManager

public javax.transaction.TransactionManager getTransactionManager()

setTransactionManager

public void setTransactionManager(javax.transaction.TransactionManager transactionManager)

createConnectionPool

protected ConnectionPool createConnectionPool(javax.jms.Connection connection)
                                       throws javax.jms.JMSException

Overrides:

createConnectionPool in class PooledConnectionFactory

Throws:

javax.jms.JMSException