org.apache.activemq.jms.pool
Class XaConnectionPool

java.lang.Object
  extended by org.apache.activemq.jms.pool.ConnectionPool
      extended by org.apache.activemq.jms.pool.XaConnectionPool
Direct Known Subclasses:
JcaConnectionPool

public class XaConnectionPool
extends ConnectionPool

An XA-aware connection pool. When a session is created and an xa transaction is active, the session will automatically be enlisted in the current transaction.

Author:
gnodet

Nested Class Summary
protected  class XaConnectionPool.Synchronization
           
 
Field Summary
 
Fields inherited from class org.apache.activemq.jms.pool.ConnectionPool
connection
 
Constructor Summary
XaConnectionPool(Connection connection, TransactionManager transactionManager)
           
 
Method Summary
 Session createSession(boolean transacted, int ackMode)
           
protected  XAResource createXaResource(PooledSession session)
           
protected  Session makeSession(SessionKey key)
           
 
Methods inherited from class org.apache.activemq.jms.pool.ConnectionPool
close, decrementReferenceCount, expiredCheck, getConnection, getExpiryTimeout, getIdleTimeout, getMaximumActiveSessionPerConnection, getNumActiveSessions, getNumIdleSessions, getNumSessions, incrementReferenceCount, isBlockIfSessionPoolIsFull, setBlockIfSessionPoolIsFull, setExpiryTimeout, setHasExpired, setIdleTimeout, setMaximumActiveSessionPerConnection, start, toString, unWrap, wrap
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

XaConnectionPool

public XaConnectionPool(Connection connection,
                        TransactionManager transactionManager)
Method Detail

makeSession

protected Session makeSession(SessionKey key)
                       throws JMSException
Overrides:
makeSession in class ConnectionPool
Throws:
JMSException

createSession

public Session createSession(boolean transacted,
                             int ackMode)
                      throws JMSException
Overrides:
createSession in class ConnectionPool
Throws:
JMSException

createXaResource

protected XAResource createXaResource(PooledSession session)
                               throws JMSException
Throws:
JMSException


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.