Package org.apache.axis.transport.jms

Class JMSConnector

java.lang.Object
org.apache.axis.transport.jms.JMSConnector
Direct Known Subclasses:
QueueConnector, TopicConnector
public abstract class JMSConnector extends Object
JMSConnector is an abstract class that encapsulates the work of connecting to JMS destinations. Its subclasses are TopicConnector and QueueConnector which further specialize connections to the pub-sub and the ptp domains. It also implements the capability to retry connections in the event of failures.
Author:
Jaime Meritt (jmeritt@sonicsoftware.com), Richard Chung (rchung@sonicsoftware.com), Dave Chappell (chappell@sonicsoftware.com), Ray Chun (rchun@sonicsoftware.com)

  • Field Details

    • m_numRetries

      protected int m_numRetries

    • m_connectRetryInterval

      protected long m_connectRetryInterval

    • m_interactRetryInterval

      protected long m_interactRetryInterval

    • m_timeoutTime

      protected long m_timeoutTime

    • m_poolTimeout

      protected long m_poolTimeout

    • m_receiveConnection

      protected JMSConnector.AsyncConnection m_receiveConnection

    • m_sendConnection

      protected JMSConnector.SyncConnection m_sendConnection

    • m_numSessions

      protected int m_numSessions

    • m_allowReceive

      protected boolean m_allowReceive

    • m_adapter

      protected JMSVendorAdapter m_adapter

    • m_jmsurl

      protected JMSURLHelper m_jmsurl

  • Constructor Details

    • JMSConnector

      public JMSConnector(ConnectionFactory connectionFactory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, String clientID, String username, String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl) throws JMSException
      Throws:
      JMSException

  • Method Details

    • getNumRetries

      public int getNumRetries()

    • numSessions

      public int numSessions()

    • getConnectionFactory

      public ConnectionFactory getConnectionFactory()

    • getClientID

      public String getClientID()

    • getUsername

      public String getUsername()

    • getPassword

      public String getPassword()

    • getVendorAdapter

      public JMSVendorAdapter getVendorAdapter()

    • getJMSURL

      public JMSURLHelper getJMSURL()

    • createConnectionWithRetry

      protected javax.jms.Connection createConnectionWithRetry(ConnectionFactory connectionFactory, String username, String password) throws JMSException
      Throws:
      JMSException

    • stop

      public void stop()

    • start

      public void start()

    • shutdown

      public void shutdown()

    • createEndpoint

      public abstract JMSEndpoint createEndpoint(String destinationName) throws JMSException
      Throws:
      JMSException

    • createEndpoint

      public abstract JMSEndpoint createEndpoint(Destination destination) throws JMSException
      Throws:
      JMSException

    • internalConnect

      protected abstract javax.jms.Connection internalConnect(ConnectionFactory connectionFactory, String username, String password) throws JMSException
      Throws:
      JMSException

    • createSyncConnection

      protected abstract JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, javax.jms.Connection connection, int numSessions, String threadName, String clientID, String username, String password) throws JMSException
      Throws:
      JMSException

    • createAsyncConnection

      protected abstract JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, javax.jms.Connection connection, String threadName, String clientID, String username, String password) throws JMSException
      Throws:
      JMSException