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

Class JMSConnectionFactory

java.lang.Object
org.wso2.carbon.inbound.endpoint.protocol.jms.factory.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 Details

    • ctx

      protected Context ctx

    • connectionFactory

      protected javax.jms.ConnectionFactory connectionFactory

    • connectionFactoryString

      protected String connectionFactoryString

    • destinationType

      protected JMSConstants.JMSDestinationType destinationType

    • 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 Details

    • JMSConnectionFactory

      public JMSConnectionFactory(Properties properties)

  • Method Details

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

    • getDestinationType

      public JMSConstants.JMSDestinationType getDestinationType()

    • 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