org.apache.axis.transport.jms
Class 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)
Constructor Summary |
| 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) |
Method Summary |
protected AsyncConnection | createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password) |
JMSEndpoint | createEndpoint(String destination) |
JMSEndpoint | createEndpoint(Destination destination)
Create an endpoint for a queue destination.
|
protected 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) |
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)
protected AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)
public
JMSEndpoint createEndpoint(Destination destination)
Create an endpoint for a queue destination.
Parameters: destination
Returns:
Throws: JMSException
protected 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)
Copyright B) 2005 Apache Web Services Project. All Rights Reserved.