public class XaConnectionPool extends ConnectionPool
Modifier and Type | Class and Description |
---|---|
protected class |
XaConnectionPool.Synchronization |
connection
Constructor and Description |
---|
XaConnectionPool(Connection connection,
TransactionManager transactionManager) |
Modifier and Type | Method and Description |
---|---|
Session |
createSession(boolean transacted,
int ackMode) |
protected XAResource |
createXaResource(PooledSession session) |
protected Session |
makeSession(SessionKey key) |
close, decrementReferenceCount, expiredCheck, getBlockIfSessionPoolIsFullTimeout, getConnection, getExpiryTimeout, getIdleTimeout, getMaximumActiveSessionPerConnection, getNumActiveSessions, getNumIdleSessions, getNumSessions, incrementReferenceCount, isBlockIfSessionPoolIsFull, isReconnectOnException, isUseAnonymousProducers, onException, setBlockIfSessionPoolIsFull, setBlockIfSessionPoolIsFullTimeout, setExpiryTimeout, setHasExpired, setIdleTimeout, setMaximumActiveSessionPerConnection, setReconnectOnException, setUseAnonymousProducers, start, toString, unWrap, wrap
public XaConnectionPool(Connection connection, TransactionManager transactionManager)
protected Session makeSession(SessionKey key) throws JMSException
makeSession
in class ConnectionPool
JMSException
public Session createSession(boolean transacted, int ackMode) throws JMSException
createSession
in class ConnectionPool
JMSException
protected XAResource createXaResource(PooledSession session) throws JMSException
JMSException
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.