org.jboss.axis.transport.jms
Class TopicConnector
java.lang.Object
org.jboss.axis.transport.jms.JMSConnector
org.jboss.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)
Constructor Summary |
TopicConnector(javax.jms.TopicConnectionFactory factory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
String clientID,
String username,
String password,
JMSVendorAdapter adapter)
|
Method Summary |
protected JMSConnector.AsyncConnection |
createAsyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
String threadName,
String clientID,
String username,
String password)
|
JMSEndpoint |
createEndpoint(javax.jms.Destination destination)
Create an endpoint for a queue destination. |
JMSEndpoint |
createEndpoint(String destination)
|
protected JMSConnector.SyncConnection |
createSyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
|
protected javax.jms.Connection |
internalConnect(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicConnector
public TopicConnector(javax.jms.TopicConnectionFactory factory,
int numRetries,
int numSessions,
long connectRetryInterval,
long interactRetryInterval,
long timeoutTime,
boolean allowReceive,
String clientID,
String username,
String password,
JMSVendorAdapter adapter)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
internalConnect
protected javax.jms.Connection internalConnect(javax.jms.ConnectionFactory connectionFactory,
String username,
String password)
throws javax.jms.JMSException
- Specified by:
internalConnect
in class JMSConnector
- Throws:
javax.jms.JMSException
createSyncConnection
protected JMSConnector.SyncConnection createSyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
int numSessions,
String threadName,
String clientID,
String username,
String password)
throws javax.jms.JMSException
- Specified by:
createSyncConnection
in class JMSConnector
- Throws:
javax.jms.JMSException
createAsyncConnection
protected JMSConnector.AsyncConnection createAsyncConnection(javax.jms.ConnectionFactory factory,
javax.jms.Connection connection,
String threadName,
String clientID,
String username,
String password)
throws javax.jms.JMSException
- Specified by:
createAsyncConnection
in class JMSConnector
- Throws:
javax.jms.JMSException
createEndpoint
public JMSEndpoint createEndpoint(String destination)
- Specified by:
createEndpoint
in class JMSConnector
createEndpoint
public JMSEndpoint createEndpoint(javax.jms.Destination destination)
throws javax.jms.JMSException
- Create an endpoint for a queue destination.
- Specified by:
createEndpoint
in class JMSConnector
- Parameters:
destination
-
- Returns:
-
- Throws:
javax.jms.JMSException
Copyright © 2002 JBoss Group, LLC. All Rights Reserved.