org.apache.axis.transport.jms
Class QueueConnector

java.lang.Object
  extended byorg.apache.axis.transport.jms.JMSConnector
      extended byorg.apache.axis.transport.jms.QueueConnector

public class QueueConnector
extends JMSConnector

QueueConnector is a concrete JMSConnector subclass that specifically handles connections to queues (ptp domain).

Author:
Jaime Meritt (jmeritt@sonicsoftware.com), Richard Chung (rchung@sonicsoftware.com), Dave Chappell (chappell@sonicsoftware.com)

Nested Class Summary
 
Nested classes inherited from class org.apache.axis.transport.jms.JMSConnector
JMSConnector.AsyncConnection, JMSConnector.SyncConnection
 
Field Summary
 
Fields inherited from class org.apache.axis.transport.jms.JMSConnector
m_adapter, m_allowReceive, m_connectRetryInterval, m_interactRetryInterval, m_jmsurl, m_numRetries, m_numSessions, m_poolTimeout, m_receiveConnection, m_sendConnection, m_timeoutTime
 
Constructor Summary
QueueConnector(ConnectionFactory factory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, java.lang.String clientID, java.lang.String username, java.lang.String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl)
           
 
Method Summary
protected  JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, org.apache.axis.transport.jms.JMSConnector.Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
           
 JMSEndpoint createEndpoint(java.lang.String destination)
           
protected  JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, org.apache.axis.transport.jms.JMSConnector.Connection connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
           
protected  org.apache.axis.transport.jms.JMSConnector.Connection internalConnect(ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password)
           
 
Methods inherited from class org.apache.axis.transport.jms.JMSConnector
createAsyncConnection, createConnectionWithRetry, createSyncConnection, getClientID, getConnectionFactory, getJMSURL, getNumRetries, getPassword, getUsername, getVendorAdapter, numSessions, shutdown, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

QueueConnector

public QueueConnector(ConnectionFactory factory,
                      int numRetries,
                      int numSessions,
                      long connectRetryInterval,
                      long interactRetryInterval,
                      long timeoutTime,
                      boolean allowReceive,
                      java.lang.String clientID,
                      java.lang.String username,
                      java.lang.String password,
                      JMSVendorAdapter adapter,
                      JMSURLHelper jmsurl)
               throws JMSException
Method Detail

createEndpoint

public JMSEndpoint createEndpoint(java.lang.String destination)
Specified by:
createEndpoint in class JMSConnector

internalConnect

protected org.apache.axis.transport.jms.JMSConnector.Connection internalConnect(ConnectionFactory connectionFactory,
                                                                                java.lang.String username,
                                                                                java.lang.String password)
                                                                         throws JMSException
Specified by:
internalConnect in class JMSConnector
Throws:
JMSException

createSyncConnection

protected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory,
                                                           org.apache.axis.transport.jms.JMSConnector.Connection connection,
                                                           int numSessions,
                                                           java.lang.String threadName,
                                                           java.lang.String clientID,
                                                           java.lang.String username,
                                                           java.lang.String password)
                                                    throws JMSException
Specified by:
createSyncConnection in class JMSConnector
Throws:
JMSException

createAsyncConnection

protected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory,
                                                             org.apache.axis.transport.jms.JMSConnector.Connection connection,
                                                             java.lang.String threadName,
                                                             java.lang.String clientID,
                                                             java.lang.String username,
                                                             java.lang.String password)
                                                      throws JMSException
Specified by:
createAsyncConnection in class JMSConnector
Throws:
JMSException


Copyright ? 2005 Apache Web Services Project. All Rights Reserved.