org.apache.axis.transport.jms
Class TopicConnector
public class TopicConnector
TopicConnector is a concrete JMSConnector subclass that specifically handles
connections to topics (pub-sub domain).
- Jaime Meritt (jmeritt@sonicsoftware.com)
- Richard Chung (rchung@sonicsoftware.com)
- Dave Chappell (chappell@sonicsoftware.com)
m_adapter , m_allowReceive , m_connectRetryInterval , m_interactRetryInterval , m_jmsurl , m_numRetries , m_numSessions , m_poolTimeout , m_receiveConnection , m_sendConnection , m_timeoutTime |
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)
|
protected JMSConnector.AsyncConnection | createAsyncConnection(ConnectionFactory factory, org.apache.axis.transport.jms.JMSConnector.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, org.apache.axis.transport.jms.JMSConnector.Connection connection, int numSessions, String threadName, String clientID, String username, String password)
|
protected org.apache.axis.transport.jms.JMSConnector.Connection | internalConnect(ConnectionFactory connectionFactory, String username, String password)
|
createAsyncConnection , createConnectionWithRetry , createEndpoint , createEndpoint , createSyncConnection , getClientID , getConnectionFactory , getJMSURL , getNumRetries , getPassword , getUsername , getVendorAdapter , internalConnect , numSessions , shutdown , start , stop |
TopicConnector
public 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
createAsyncConnection
protected JMSConnector.AsyncConnection createAsyncConnection(ConnectionFactory factory,
org.apache.axis.transport.jms.JMSConnector.Connection connection,
String threadName,
String clientID,
String username,
String password)
throws JMSException
createEndpoint
public JMSEndpoint createEndpoint(Destination destination)
throws JMSException
Create an endpoint for a queue destination.
- createEndpoint in interface JMSConnector
destination
-
createSyncConnection
protected JMSConnector.SyncConnection createSyncConnection(ConnectionFactory factory,
org.apache.axis.transport.jms.JMSConnector.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
throws JMSException
internalConnect
protected org.apache.axis.transport.jms.JMSConnector.Connection internalConnect(ConnectionFactory connectionFactory,
String username,
String password)
throws JMSException
- internalConnect in interface JMSConnector
Copyright B) 2005 Apache Web Services Project. All Rights Reserved.