org.jboss.axis.transport.jms
Class TopicConnector
java.lang.Object
org.jboss.axis.transport.jms.JMSConnector (src)
org.jboss.axis.transport.jms.TopicConnector
- public class TopicConnector
- extends JMSConnector (src)
TopicConnector is a concrete JMSConnector subclass that specifically handles
connections to topics (pub-sub domain).
Constructor Summary |
TopicConnector(TopicConnectionFactory (src) 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 (src) adapter)
|
Method Summary |
protected JMSConnector.AsyncConnection (src) |
createAsyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
|
JMSEndpoint (src) |
createEndpoint(Destination (src) destination)
Create an endpoint for a queue destination. |
JMSEndpoint (src) |
createEndpoint(java.lang.String destination)
|
protected JMSConnector.SyncConnection (src) |
createSyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
int numSessions,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
|
protected Connection (src) |
internalConnect(ConnectionFactory (src) connectionFactory,
java.lang.String username,
java.lang.String password)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicConnector
public TopicConnector(TopicConnectionFactory (src) 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 (src) adapter)
throws JMSException (src)
internalConnect
protected Connection (src) internalConnect(ConnectionFactory (src) connectionFactory,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
internalConnect
in class JMSConnector (src)
- Throws:
JMSException (src)
createSyncConnection
protected JMSConnector.SyncConnection (src) createSyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
int numSessions,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
createSyncConnection
in class JMSConnector (src)
- Throws:
JMSException (src)
createAsyncConnection
protected JMSConnector.AsyncConnection (src) createAsyncConnection(ConnectionFactory (src) factory,
Connection (src) connection,
java.lang.String threadName,
java.lang.String clientID,
java.lang.String username,
java.lang.String password)
throws JMSException (src)
- Specified by:
createAsyncConnection
in class JMSConnector (src)
- Throws:
JMSException (src)
createEndpoint
public JMSEndpoint (src) createEndpoint(java.lang.String destination)
- Specified by:
createEndpoint
in class JMSConnector (src)
createEndpoint
public JMSEndpoint (src) createEndpoint(Destination (src) destination)
throws JMSException (src)
- Create an endpoint for a queue destination.
- Specified by:
createEndpoint
in class JMSConnector (src)
- Parameters:
destination
-
- Returns:
-
- Throws:
JMSException (src)