org.apache.axis.transport.jms
Class QueueConnector
java.lang.Object
org.apache.axis.transport.jms.JMSConnector
org.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)
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 |
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
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.