public class TopicConnector 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 |
|---|
TopicConnector(TopicConnectionFactory 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 TopicConnector(TopicConnectionFactory 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
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 JMSConnectorJMSExceptionpublic JMSEndpoint createEndpoint(String destination)
createEndpoint in class JMSConnectorpublic JMSEndpoint createEndpoint(Destination destination) throws JMSException
createEndpoint in class JMSConnectordestination - JMSExceptionCopyright © The Apache Software Foundation. All Rights Reserved.