org.jboss.axis.transport.jms
Class QueueConnector

java.lang.Object
  extended byorg.jboss.axis.transport.jms.JMSConnector (src) 
      extended byorg.jboss.axis.transport.jms.QueueConnector

public class QueueConnector
extends JMSConnector (src)

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


Nested Class Summary
 
Nested classes inherited from class org.jboss.axis.transport.jms.JMSConnector (src)
JMSConnector.AsyncConnection (src) , JMSConnector.SyncConnection (src)
 
Field Summary
 
Fields inherited from class org.jboss.axis.transport.jms.JMSConnector (src)
m_adapter, m_allowReceive, m_connectRetryInterval, m_interactRetryInterval, m_numRetries, m_numSessions, m_poolTimeout, m_receiveConnection, m_sendConnection, m_timeoutTime
 
Constructor Summary
QueueConnector(ConnectionFactory (src)  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 (src)  adapter)
           
 
Method Summary
protected  JMSConnector.AsyncConnection (src) createAsyncConnection(ConnectionFactory (src)  factory, Connection (src)  connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
           
 JMSEndpoint (src) createEndpoint(Destination (src)  destination)
          Create an endpoint for a queue destination.
 JMSEndpoint (src) createEndpoint(java.lang.String destination)
           
protected  JMSConnector.SyncConnection (src) createSyncConnection(ConnectionFactory (src)  factory, Connection (src)  connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
           
protected  Connection (src) internalConnect(ConnectionFactory (src)  connectionFactory, java.lang.String username, java.lang.String password)
           
 
Methods inherited from class org.jboss.axis.transport.jms.JMSConnector (src)
createConnectionWithRetry, 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 (src)  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 (src)  adapter)
               throws JMSException (src) 
Method Detail

createEndpoint

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

createEndpoint

public JMSEndpoint (src)  createEndpoint(Destination (src)  destination)
                           throws JMSException (src) 
Create an endpoint for a queue destination.

Specified by:
createEndpoint in class JMSConnector (src)
Parameters:
destination -
Returns:
Throws:
JMSException (src)

internalConnect

protected Connection (src)  internalConnect(ConnectionFactory (src)  connectionFactory,
                                     java.lang.String username,
                                     java.lang.String password)
                              throws JMSException (src) 
Specified by:
internalConnect in class JMSConnector (src)
Throws:
JMSException (src)

createSyncConnection

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

createAsyncConnection

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