Package org.wso2.carbon.inbound.endpoint.protocol.jms.factory

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CachedJMSConnectionFactory

public CachedJMSConnectionFactory(Properties properties)

CachedJMSConnectionFactory

public CachedJMSConnectionFactory(Properties properties,
 javax.jms.Connection cachedConnection)

Method Details

getConnectionFactory

public javax.jms.ConnectionFactory getConnectionFactory()

Overrides:

getConnectionFactory in class JMSConnectionFactory

getConnection

public javax.jms.Connection getConnection(String userName,
 String password)

createConnection

public javax.jms.Connection createConnection(String userName,
 String password)

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Overrides:

createConnection in class JMSConnectionFactory

getSession

public javax.jms.Session getSession(javax.jms.Connection connection)

Overrides:

getSession in class JMSConnectionFactory

createSession

protected javax.jms.Session createSession(javax.jms.Connection connection)

Overrides:

createSession in class JMSConnectionFactory

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 class JMSConnectionFactory

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 class JMSConnectionFactory

Parameters:

session - JMS session

destination - the Destination

isQueue - 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 class JMSConnectionFactory

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() on

forcefully - 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 class JMSConnectionFactory