当前页面:
在线文档首页 >
JBoss 4.0.1 sp1 jaxrpc API Documentation 英文版文档
TopicConnector (JAXRPC API) - JBoss 4.0.1 sp1 jaxrpc API Documentation 英文版文档
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)
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
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.