public class XaConnectionPool extends ConnectionPool
Modifier and Type | Class and Description |
---|---|
protected class |
XaConnectionPool.Synchronization |
Constructor and Description |
---|
XaConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory,
javax.transaction.TransactionManager transactionManager) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int ackMode) |
protected javax.transaction.xa.XAResource |
createXaResource(PooledSession session) |
close, createSessionPool, decrementReferenceCount, expiredCheck, getConnection, getExpiryTimeout, getIdleTimeout, incrementReferenceCount, setExpiryTimeout, setIdleTimeout, start
public XaConnectionPool(ActiveMQConnection connection, org.apache.commons.pool.ObjectPoolFactory poolFactory, javax.transaction.TransactionManager transactionManager)
public javax.jms.Session createSession(boolean transacted, int ackMode) throws javax.jms.JMSException
createSession
in class ConnectionPool
javax.jms.JMSException
protected javax.transaction.xa.XAResource createXaResource(PooledSession session) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005-2012. All Rights Reserved.