public class QueueConnector extends JMSConnector
JMSConnector.AsyncConnection, JMSConnector.SyncConnectionm_adapter, m_allowReceive, m_connectRetryInterval, m_interactRetryInterval, m_jmsurl, m_numRetries, m_numSessions, m_poolTimeout, m_receiveConnection, m_sendConnection, m_timeoutTime| Constructor and Description |
|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
protected JMSConnector.AsyncConnection |
createAsyncConnection(ConnectionFactory factory,
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,
Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password) |
protected Connection |
internalConnect(ConnectionFactory connectionFactory,
String username,
String password) |
createConnectionWithRetry, getClientID, getConnectionFactory, getJMSURL, getNumRetries, getPassword, getUsername, getVendorAdapter, numSessions, shutdown, start, stoppublic 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
JMSExceptionpublic JMSEndpoint createEndpoint(String destination)
createEndpoint in class JMSConnectorpublic JMSEndpoint createEndpoint(Destination destination) throws JMSException
createEndpoint in class JMSConnectordestination - JMSExceptionprotected Connection internalConnect(ConnectionFactory connectionFactory, String username, String password) throws JMSException
internalConnect in class JMSConnectorJMSExceptionprotected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password) throws JMSException
createSyncConnection in class JMSConnectorJMSExceptionprotected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password) throws JMSException
createAsyncConnection in class JMSConnectorJMSExceptionCopyright © The Apache Software Foundation. All Rights Reserved.