Class CachedJMSConnectionFactory

  • All Implemented Interfaces:
    javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory

    public class CachedJMSConnectionFactory
    extends JMSConnectionFactory
    • Constructor Detail

      • CachedJMSConnectionFactory

        public CachedJMSConnectionFactory​(Properties properties)
      • CachedJMSConnectionFactory

        public CachedJMSConnectionFactory​(Properties properties,
                                          javax.jms.Connection cachedConnection)
    • Method Detail

      • getConnection

        public javax.jms.Connection getConnection​(String userName,
                                                  String password)
      • 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()
      • 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)