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,
TransactionManager transactionManager) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int ackMode) |
protected 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, TransactionManager transactionManager)
public javax.jms.Session createSession(boolean transacted, int ackMode) throws javax.jms.JMSException
createSession
in class ConnectionPool
javax.jms.JMSException
protected XAResource createXaResource(PooledSession session) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005–2014. All rights reserved.