Class JMSConnectionFactory

  • All Implemented Interfaces:
    javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory
    Direct Known Subclasses:
    CachedJMSConnectionFactory

    public class JMSConnectionFactory
    extends Object
    implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory
    use of factory server down and up jms spec transport.jms.MessageSelector isDurable
    • Field Detail

      • connectionFactory

        protected javax.jms.ConnectionFactory connectionFactory
      • connectionFactoryString

        protected String connectionFactoryString
      • destinationName

        protected String destinationName
      • transactedSession

        protected boolean transactedSession
      • sessionAckMode

        protected int sessionAckMode
      • jmsSpec

        protected String jmsSpec
      • isDurable

        protected boolean isDurable
      • noPubSubLocal

        protected boolean noPubSubLocal
      • clientId

        protected String clientId
      • subscriptionName

        protected String subscriptionName
      • messageSelector

        protected String messageSelector
      • isSharedSubscription

        protected boolean isSharedSubscription
    • Constructor Detail

      • JMSConnectionFactory

        public JMSConnectionFactory​(Properties properties)
    • Method Detail

      • getConnectionFactory

        public javax.jms.ConnectionFactory getConnectionFactory()
      • getConnection

        public javax.jms.Connection getConnection()
      • createConnection

        public javax.jms.Connection createConnection()
        Specified by:
        createConnection in interface javax.jms.ConnectionFactory
      • createConnection

        public javax.jms.Connection createConnection​(String userName,
                                                     String password)
        Specified by:
        createConnection in interface javax.jms.ConnectionFactory
      • createQueueConnection

        public javax.jms.QueueConnection createQueueConnection()
                                                        throws javax.jms.JMSException
        Specified by:
        createQueueConnection in interface javax.jms.QueueConnectionFactory
        Throws:
        javax.jms.JMSException
      • createQueueConnection

        public javax.jms.QueueConnection createQueueConnection​(String userName,
                                                               String password)
                                                        throws javax.jms.JMSException
        Specified by:
        createQueueConnection in interface javax.jms.QueueConnectionFactory
        Throws:
        javax.jms.JMSException
      • createTopicConnection

        public javax.jms.TopicConnection createTopicConnection()
                                                        throws javax.jms.JMSException
        Specified by:
        createTopicConnection in interface javax.jms.TopicConnectionFactory
        Throws:
        javax.jms.JMSException
      • createTopicConnection

        public javax.jms.TopicConnection createTopicConnection​(String userName,
                                                               String password)
                                                        throws javax.jms.JMSException
        Specified by:
        createTopicConnection in interface javax.jms.TopicConnectionFactory
        Throws:
        javax.jms.JMSException
      • getDestination

        public javax.jms.Destination getDestination​(javax.jms.Session session)
      • createMessageConsumer

        public javax.jms.MessageConsumer createMessageConsumer​(javax.jms.Session session,
                                                               javax.jms.Destination destination)
      • 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
        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
      • createDestination

        public javax.jms.Destination createDestination​(javax.jms.Session session,
                                                       String destinationName)
      • getSession

        public javax.jms.Session getSession​(javax.jms.Connection connection)
      • createSession

        protected javax.jms.Session createSession​(javax.jms.Connection connection)
      • start

        public void start​(javax.jms.Connection connection)
      • stop

        public void stop​(javax.jms.Connection connection)
      • closeConnection

        public boolean closeConnection​(javax.jms.Connection connection)
      • getContext

        public Context getContext()
      • getConnectionFactoryString

        public String getConnectionFactoryString()
      • isTransactedSession

        public boolean isTransactedSession()
      • getSessionAckMode

        public int getSessionAckMode()
      • createContext

        public javax.jms.JMSContext createContext()
        Specified by:
        createContext in interface javax.jms.ConnectionFactory
      • createContext

        public javax.jms.JMSContext createContext​(int sessionMode)
        Specified by:
        createContext in interface javax.jms.ConnectionFactory
      • createContext

        public javax.jms.JMSContext createContext​(String userName,
                                                  String password)
        Specified by:
        createContext in interface javax.jms.ConnectionFactory
      • createContext

        public javax.jms.JMSContext createContext​(String userName,
                                                  String password,
                                                  int sessionMode)
        Specified by:
        createContext in interface javax.jms.ConnectionFactory