Class CachedJMSConnectionFactory
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.jms.factory.JMSConnectionFactory
-
- org.wso2.carbon.inbound.endpoint.protocol.jms.factory.CachedJMSConnectionFactory
-
- All Implemented Interfaces:
javax.jms.ConnectionFactory
,javax.jms.QueueConnectionFactory
,javax.jms.TopicConnectionFactory
public class CachedJMSConnectionFactory extends JMSConnectionFactory
-
-
Field Summary
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.protocol.jms.factory.JMSConnectionFactory
clientId, connectionFactory, connectionFactoryString, ctx, destinationName, destinationType, isDurable, isSharedSubscription, jmsSpec, messageSelector, noPubSubLocal, sessionAckMode, subscriptionName, transactedSession
-
-
Constructor Summary
Constructors Constructor Description CachedJMSConnectionFactory(Properties properties)
CachedJMSConnectionFactory(Properties properties, javax.jms.Connection cachedConnection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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-
Methods inherited from class org.wso2.carbon.inbound.endpoint.protocol.jms.factory.JMSConnectionFactory
createConnection, createContext, createContext, createContext, createContext, createDestination, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getConnection, getConnectionFactoryString, getContext, getDestination, getSessionAckMode, isTransactedSession, start, stop
-
-
-
-
Constructor Detail
-
CachedJMSConnectionFactory
public CachedJMSConnectionFactory(Properties properties)
-
CachedJMSConnectionFactory
public CachedJMSConnectionFactory(Properties properties, javax.jms.Connection cachedConnection)
-
-
Method Detail
-
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
- Overrides:
getConnectionFactory
in classJMSConnectionFactory
-
createConnection
public javax.jms.Connection createConnection(String userName, String password)
- Specified by:
createConnection
in interfacejavax.jms.ConnectionFactory
- Overrides:
createConnection
in classJMSConnectionFactory
-
getSession
public javax.jms.Session getSession(javax.jms.Connection connection)
- Overrides:
getSession
in classJMSConnectionFactory
-
createSession
protected javax.jms.Session createSession(javax.jms.Connection connection)
- Overrides:
createSession
in classJMSConnectionFactory
-
getMessageConsumer
public javax.jms.MessageConsumer getMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
-
createMessageConsumer
public javax.jms.MessageConsumer createMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
- Overrides:
createMessageConsumer
in classJMSConnectionFactory
-
createProducer
public javax.jms.MessageProducer createProducer(javax.jms.Session session, javax.jms.Destination destination, Boolean isQueue) throws javax.jms.JMSException
This is a JMS spec independent method to create a MessageProducer. Please be cautious when making any changes- Overrides:
createProducer
in classJMSConnectionFactory
- Parameters:
session
- JMS sessiondestination
- the DestinationisQueue
- is the Destination a queue?jmsSpec11
- should we use JMS 1.1 API ?- Returns:
- a MessageProducer to send messages to the given Destination
- Throws:
javax.jms.JMSException
- on errors, to be handled and logged by the caller
-
closeConnection
public boolean closeConnection()
-
closeConnection
public boolean closeConnection(javax.jms.Connection connection)
- Overrides:
closeConnection
in classJMSConnectionFactory
-
closeConsumer
public boolean closeConsumer(javax.jms.MessageConsumer messageConsumer)
-
closeSession
public boolean closeSession(javax.jms.Session session)
-
closeConnection
public boolean closeConnection(javax.jms.Connection connection, boolean forcefully)
-
recoverSession
public void recoverSession(javax.jms.Session session, boolean forcefully) throws javax.jms.JMSException
Recover JMS session- Parameters:
session
- JMS session to issue recover() onforcefully
- True if recover needs to be done without conditions. Otherwise, recover will be done based on cache level- Throws:
javax.jms.JMSException
- Upon error recovering the session
-
closeConsumer
public boolean closeConsumer(javax.jms.MessageConsumer messageConsumer, boolean forcefully)
-
closeSession
public boolean closeSession(javax.jms.Session session, boolean forcefully)
-
getDestinationType
public JMSConstants.JMSDestinationType getDestinationType()
- Overrides:
getDestinationType
in classJMSConnectionFactory
-
-