org.apache.axis.transport.jms
Class TopicConnector
java.lang.Object
org.apache.axis.transport.jms.JMSConnector
org.apache.axis.transport.jms.TopicConnector
public class TopicConnector
- extends JMSConnector
TopicConnector is a concrete JMSConnector subclass that specifically handles
connections to topics (pub-sub 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 |
TopicConnector(TopicConnectionFactory 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,
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicConnector
public TopicConnector(TopicConnectionFactory 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
internalConnect
protected 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,
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,
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
createEndpoint
public JMSEndpoint createEndpoint(java.lang.String destination)
- Specified by:
createEndpoint
in class JMSConnector
createEndpoint
public JMSEndpoint createEndpoint(Destination destination)
throws JMSException
- Create an endpoint for a queue destination.
- Specified by:
createEndpoint
in class JMSConnector
- Parameters:
destination
-
- Returns:
-
- Throws:
JMSException
Copyright ? 2005 Apache Web Services Project. All Rights Reserved.