public class XaConnectionPool extends ConnectionPool
Modifier and Type | Class and Description |
---|---|
protected class |
XaConnectionPool.Synchronization |
connection
Constructor and Description |
---|
XaConnectionPool(javax.jms.Connection connection,
TransactionManager transactionManager) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int ackMode) |
protected XAResource |
createXaResource(PooledSession session) |
protected javax.jms.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(javax.jms.Connection connection, TransactionManager transactionManager)
protected javax.jms.Session makeSession(SessionKey key) throws javax.jms.JMSException
makeSession
in class ConnectionPool
javax.jms.JMSException
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–2018 FuseSource, Corp.. All rights reserved.