org.apache.axis2.transport.jms
Class JMSConnector.AsyncConnection

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.apache.axis2.transport.jms.JMSConnector.Connection
          extended byorg.apache.axis2.transport.jms.JMSConnector.AsyncConnection
All Implemented Interfaces:
javax.jms.ExceptionListener, Runnable
Enclosing class:
JMSConnector

protected abstract class JMSConnector.AsyncConnection
extends org.apache.axis2.transport.jms.JMSConnector.Connection


Nested Class Summary
protected  class JMSConnector.AsyncConnection.ListenerSession
           
 
Field Summary
protected  javax.jms.Connection m_connection
           
protected  boolean m_isActive
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
protected JMSConnector.AsyncConnection(javax.jms.ConnectionFactory connectionFactory, javax.jms.Connection connection, String threadName, String clientID, String username, String password)
           
 
Method Summary
protected abstract  JMSConnector.AsyncConnection.ListenerSession createListenerSession(javax.jms.Connection connection, Subscription subscription)
           
 String getClientID()
           
 javax.jms.ConnectionFactory getConnectionFactory()
           
 String getPassword()
           
 String getUsername()
           
protected  void onConnect()
           
protected  void onException()
           
 void onException(javax.jms.JMSException exception)
           
protected  void onShutdown()
           
 void run()
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

m_connection

protected javax.jms.Connection m_connection

m_isActive

protected boolean m_isActive
Constructor Detail

JMSConnector.AsyncConnection

protected JMSConnector.AsyncConnection(javax.jms.ConnectionFactory connectionFactory,
                                       javax.jms.Connection connection,
                                       String threadName,
                                       String clientID,
                                       String username,
                                       String password)
                                throws javax.jms.JMSException
Method Detail

createListenerSession

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

onConnect

protected void onConnect()
                  throws Exception
Throws:
Exception

onException

protected void onException()

onShutdown

protected void onShutdown()

onException

public void onException(javax.jms.JMSException exception)
Specified by:
onException in interface javax.jms.ExceptionListener

run

public void run()
Specified by:
run in interface Runnable

getClientID

public String getClientID()

getConnectionFactory

public javax.jms.ConnectionFactory getConnectionFactory()

getPassword

public String getPassword()

getUsername

public String getUsername()