Package 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)
-
-
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
Constructors Constructor Description 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected JMSConnector.AsyncConnection
createAsyncConnection(ConnectionFactory factory, Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
JMSEndpoint
createEndpoint(Destination destination)
Create an endpoint for a queue destination.JMSEndpoint
createEndpoint(java.lang.String destination)
protected JMSConnector.SyncConnection
createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
protected Connection
internalConnect(ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password)
-
Methods inherited from class org.apache.axis.transport.jms.JMSConnector
createConnectionWithRetry, getClientID, getConnectionFactory, getJMSURL, getNumRetries, getPassword, getUsername, getVendorAdapter, numSessions, shutdown, start, stop
-
-
-
-
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
- Throws:
JMSException
-
-
Method Detail
-
createEndpoint
public JMSEndpoint createEndpoint(java.lang.String destination)
- Specified by:
createEndpoint
in classJMSConnector
-
createEndpoint
public JMSEndpoint createEndpoint(Destination destination) throws JMSException
Create an endpoint for a queue destination.- Specified by:
createEndpoint
in classJMSConnector
- Parameters:
destination
-- Returns:
- Throws:
JMSException
-
internalConnect
protected Connection internalConnect(ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password) throws JMSException
- Specified by:
internalConnect
in classJMSConnector
- Throws:
JMSException
-
createSyncConnection
protected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, 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 classJMSConnector
- Throws:
JMSException
-
createAsyncConnection
protected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password) throws JMSException
- Specified by:
createAsyncConnection
in classJMSConnector
- Throws:
JMSException
-
-