org.apache.axis.transport.jms

Class QueueConnector


public class QueueConnector
extends JMSConnector

QueueConnector is a concrete JMSConnector subclass that specifically handles connections to queues (ptp domain).
Authors:
Jaime Meritt (jmeritt@sonicsoftware.com)
Richard Chung (rchung@sonicsoftware.com)
Dave Chappell (chappell@sonicsoftware.com)

Nested Class Summary

Nested classes/interfaces 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, String clientID, String username, String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl)

Method Summary

protected JMSConnector.AsyncConnection
createAsyncConnection(ConnectionFactory factory, org.apache.axis.transport.jms.JMSConnector.Connection connection, String threadName, String clientID, String username, String password)
JMSEndpoint
createEndpoint(Destination destination)
Create an endpoint for a queue destination.
JMSEndpoint
createEndpoint(String destination)
protected JMSConnector.SyncConnection
createSyncConnection(ConnectionFactory factory, org.apache.axis.transport.jms.JMSConnector.Connection connection, int numSessions, String threadName, String clientID, String username, String password)
protected org.apache.axis.transport.jms.JMSConnector.Connection
internalConnect(ConnectionFactory connectionFactory, String username, String password)

Methods inherited from class org.apache.axis.transport.jms.JMSConnector

createAsyncConnection, createConnectionWithRetry, createEndpoint, createEndpoint, createSyncConnection, getClientID, getConnectionFactory, getJMSURL, getNumRetries, getPassword, getUsername, getVendorAdapter, internalConnect, numSessions, shutdown, start, stop

Constructor Details

QueueConnector

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

Method Details

createAsyncConnection

protected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory,
                                                             org.apache.axis.transport.jms.JMSConnector.Connection connection,
                                                             String threadName,
                                                             String clientID,
                                                             String username,
                                                             String password)
            throws JMSException

createEndpoint

public JMSEndpoint createEndpoint(Destination destination)
            throws JMSException
Create an endpoint for a queue destination.
Overrides:
createEndpoint in interface JMSConnector
Parameters:
destination -
Returns:

createEndpoint

public JMSEndpoint createEndpoint(String destination)
Overrides:
createEndpoint in interface JMSConnector

createSyncConnection

protected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory,
                                                           org.apache.axis.transport.jms.JMSConnector.Connection connection,
                                                           int numSessions,
                                                           String threadName,
                                                           String clientID,
                                                           String username,
                                                           String password)
            throws JMSException

internalConnect

protected org.apache.axis.transport.jms.JMSConnector.Connection internalConnect(ConnectionFactory connectionFactory,
                                                                                String username,
                                                                                String password)
            throws JMSException
Overrides:
internalConnect in interface JMSConnector

Copyright B) 2005 Apache Web Services Project. All Rights Reserved.