|
The Spring Framework | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.jms.connection.ConnectionFactoryUtils
public abstract class ConnectionFactoryUtils
Helper class for managing a JMS ConnectionFactory
, in particular
for obtaining transactional JMS resources for a given ConnectionFactory.
Mainly for internal use within the framework. Used by
JmsTemplate
as well as
DefaultMessageListenerContainer
.
SmartConnectionFactory
Nested Class Summary | |
---|---|
static interface |
ConnectionFactoryUtils.ResourceFactory
Callback interface for resource creation. |
Constructor Summary | |
---|---|
ConnectionFactoryUtils()
|
Method Summary | |
---|---|
static Session |
doGetTransactionalSession(ConnectionFactory connectionFactory,
ConnectionFactoryUtils.ResourceFactory resourceFactory)
Obtain a JMS Session that is synchronized with the current transaction, if any. |
static QueueSession |
getTransactionalQueueSession(QueueConnectionFactory cf,
QueueConnection existingCon,
boolean synchedLocalTransactionAllowed)
Obtain a JMS QueueSession that is synchronized with the current transaction, if any. |
static Session |
getTransactionalSession(ConnectionFactory cf,
Connection existingCon,
boolean synchedLocalTransactionAllowed)
Obtain a JMS Session that is synchronized with the current transaction, if any. |
static TopicSession |
getTransactionalTopicSession(TopicConnectionFactory cf,
TopicConnection existingCon,
boolean synchedLocalTransactionAllowed)
Obtain a JMS TopicSession that is synchronized with the current transaction, if any. |
static boolean |
isSessionTransactional(Session session,
ConnectionFactory cf)
Determine whether the given JMS Session is transactional, that is, bound to the current thread by Spring's transaction facilities. |
static void |
releaseConnection(Connection con,
ConnectionFactory cf,
boolean started)
Release the given Connection, stopping it (if necessary) and eventually closing it. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ConnectionFactoryUtils()
Method Detail |
---|
public static void releaseConnection(Connection con, ConnectionFactory cf, boolean started)
Checks SmartConnectionFactory.shouldStop(javax.jms.Connection)
, if available.
This is essentially a more sophisticated version of
JmsUtils.closeConnection(javax.jms.Connection)
.
con
- the Connection to release
(if this is null
, the call will be ignored)cf
- the ConnectionFactory that the Connection was obtained from
(may be null
)started
- whether the Connection might have been started by the applicationSmartConnectionFactory.shouldStop(javax.jms.Connection)
,
JmsUtils.closeConnection(javax.jms.Connection)
public static boolean isSessionTransactional(Session session, ConnectionFactory cf)
session
- the JMS Session to checkcf
- the JMS ConnectionFactory that the Session originated from
public static Session getTransactionalSession(ConnectionFactory cf, Connection existingCon, boolean synchedLocalTransactionAllowed) throws JMSException
cf
- the ConnectionFactory to obtain a Session forexistingCon
- the existing JMS Connection to obtain a Session for
(may be null
)synchedLocalTransactionAllowed
- whether to allow for a local JMS transaction
that is synchronized with a Spring-managed transaction (where the main transaction
might be a JDBC-based one for a specific DataSource, for example), with the JMS
transaction committing right after the main transaction. If not allowed, the given
ConnectionFactory needs to handle transaction enlistment underneath the covers.
null
if none found
JMSException
- in case of JMS failurepublic static QueueSession getTransactionalQueueSession(QueueConnectionFactory cf, QueueConnection existingCon, boolean synchedLocalTransactionAllowed) throws JMSException
Mainly intended for use with the JMS 1.0.2 API.
cf
- the ConnectionFactory to obtain a Session forexistingCon
- the existing JMS Connection to obtain a Session for
(may be null
)synchedLocalTransactionAllowed
- whether to allow for a local JMS transaction
that is synchronized with a Spring-managed transaction (where the main transaction
might be a JDBC-based one for a specific DataSource, for example), with the JMS
transaction committing right after the main transaction. If not allowed, the given
ConnectionFactory needs to handle transaction enlistment underneath the covers.
null
if none found
JMSException
- in case of JMS failurepublic static TopicSession getTransactionalTopicSession(TopicConnectionFactory cf, TopicConnection existingCon, boolean synchedLocalTransactionAllowed) throws JMSException
Mainly intended for use with the JMS 1.0.2 API.
cf
- the ConnectionFactory to obtain a Session forexistingCon
- the existing JMS Connection to obtain a Session for
(may be null
)synchedLocalTransactionAllowed
- whether to allow for a local JMS transaction
that is synchronized with a Spring-managed transaction (where the main transaction
might be a JDBC-based one for a specific DataSource, for example), with the JMS
transaction committing right after the main transaction. If not allowed, the given
ConnectionFactory needs to handle transaction enlistment underneath the covers.
null
if none found
JMSException
- in case of JMS failurepublic static Session doGetTransactionalSession(ConnectionFactory connectionFactory, ConnectionFactoryUtils.ResourceFactory resourceFactory) throws JMSException
connectionFactory
- the JMS ConnectionFactory to bind for
(used as TransactionSynchronizationManager key)resourceFactory
- the ResourceFactory to use for extracting or creating
JMS resources
null
if none found
JMSException
- in case of JMS failure
|
The Spring Framework | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |