public class CachedJMSConnectionFactory extends JMSConnectionFactory
clientId, connectionFactory, connectionFactoryString, ctx, destinationName, destinationType, isDurable, isSharedSubscription, jmsSpec, messageSelector, noPubSubLocal, sessionAckMode, subscriptionName, transactedSession
Constructor and Description |
---|
CachedJMSConnectionFactory(Properties properties) |
CachedJMSConnectionFactory(Properties properties,
javax.jms.Connection cachedConnection) |
Modifier and Type | Method and Description |
---|---|
boolean |
closeConnection() |
boolean |
closeConnection(javax.jms.Connection connection) |
boolean |
closeConnection(javax.jms.Connection connection,
boolean forcefully) |
boolean |
closeConsumer(javax.jms.MessageConsumer messageConsumer) |
boolean |
closeConsumer(javax.jms.MessageConsumer messageConsumer,
boolean forcefully) |
boolean |
closeSession(javax.jms.Session session) |
boolean |
closeSession(javax.jms.Session session,
boolean forcefully) |
javax.jms.Connection |
createConnection(String userName,
String password) |
javax.jms.MessageConsumer |
createMessageConsumer(javax.jms.Session session,
javax.jms.Destination destination) |
javax.jms.MessageProducer |
createProducer(javax.jms.Session session,
javax.jms.Destination destination,
Boolean isQueue)
This is a JMS spec independent method to create a MessageProducer.
|
protected javax.jms.Session |
createSession(javax.jms.Connection connection) |
javax.jms.Connection |
getConnection(String userName,
String password) |
javax.jms.ConnectionFactory |
getConnectionFactory() |
JMSConstants.JMSDestinationType |
getDestinationType() |
javax.jms.MessageConsumer |
getMessageConsumer(javax.jms.Session session,
javax.jms.Destination destination) |
javax.jms.Session |
getSession(javax.jms.Connection connection) |
void |
recoverSession(javax.jms.Session session,
boolean forcefully)
Recover JMS session
|
createConnection, createContext, createContext, createContext, createContext, createDestination, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getConnection, getConnectionFactoryString, getContext, getDestination, getSessionAckMode, isTransactedSession, start, stop
public CachedJMSConnectionFactory(Properties properties)
public CachedJMSConnectionFactory(Properties properties, javax.jms.Connection cachedConnection)
public javax.jms.ConnectionFactory getConnectionFactory()
getConnectionFactory
in class JMSConnectionFactory
public javax.jms.Connection createConnection(String userName, String password)
createConnection
in interface javax.jms.ConnectionFactory
createConnection
in class JMSConnectionFactory
public javax.jms.Session getSession(javax.jms.Connection connection)
getSession
in class JMSConnectionFactory
protected javax.jms.Session createSession(javax.jms.Connection connection)
createSession
in class JMSConnectionFactory
public javax.jms.MessageConsumer getMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
public javax.jms.MessageConsumer createMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
createMessageConsumer
in class JMSConnectionFactory
public javax.jms.MessageProducer createProducer(javax.jms.Session session, javax.jms.Destination destination, Boolean isQueue) throws javax.jms.JMSException
createProducer
in class JMSConnectionFactory
session
- JMS sessiondestination
- the DestinationisQueue
- is the Destination a queue?jmsSpec11
- should we use JMS 1.1 API ?javax.jms.JMSException
- on errors, to be handled and logged by the callerpublic boolean closeConnection()
public boolean closeConnection(javax.jms.Connection connection)
closeConnection
in class JMSConnectionFactory
public boolean closeConsumer(javax.jms.MessageConsumer messageConsumer)
public boolean closeSession(javax.jms.Session session)
public boolean closeConnection(javax.jms.Connection connection, boolean forcefully)
public void recoverSession(javax.jms.Session session, boolean forcefully) throws javax.jms.JMSException
session
- JMS session to issue recover() onforcefully
- True if recover needs to be done without conditions. Otherwise, recover
will be done based on cache leveljavax.jms.JMSException
- Upon error recovering the sessionpublic boolean closeConsumer(javax.jms.MessageConsumer messageConsumer, boolean forcefully)
public boolean closeSession(javax.jms.Session session, boolean forcefully)
public JMSConstants.JMSDestinationType getDestinationType()
getDestinationType
in class JMSConnectionFactory
Copyright © 2021 WSO2. All rights reserved.