Class JMSConnector.AsyncConnection

java.lang.Object
java.lang.Thread
org.apache.axis.transport.jms.JMSConnector.AsyncConnection
All Implemented Interfaces:
Runnable
Enclosing class:
JMSConnector

protected abstract class JMSConnector.AsyncConnection extends Thread
  • Field Details

    • m_connection

      protected javax.jms.Connection m_connection
    • m_isActive

      protected boolean m_isActive
  • Constructor Details

    • AsyncConnection

      protected AsyncConnection(ConnectionFactory connectionFactory, javax.jms.Connection connection, String threadName, String clientID, String username, String password) throws JMSException
      Throws:
      JMSException
  • Method Details

    • createListenerSession

      protected abstract JMSConnector.AsyncConnection.ListenerSession createListenerSession(javax.jms.Connection connection, Subscription subscription) throws Exception
      Throws:
      Exception
    • onShutdown

      protected void onShutdown()
    • onConnect

      protected void onConnect() throws Exception
      Throws:
      Exception
    • onException

      protected void onException()
    • getConnectionFactory

      public ConnectionFactory getConnectionFactory()
    • getClientID

      public String getClientID()
    • getUsername

      public String getUsername()
    • getPassword

      public String getPassword()
    • run

      public void run()
      Specified by:
      run in interface Runnable
      Overrides:
      run in class Thread
    • onException

      public void onException(JMSException exception)