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).

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.axis.transport.jms.JMSConnector

JMSConnector.AsyncConnection, JMSConnector.SyncConnection

Field Summary

Fields inherited from class org.apache.axis.transport.jms.JMSConnector

m_adapter, m_allowReceive, m_connectRetryInterval, m_interactRetryInterval, m_jmsurl, m_numRetries, m_numSessions, m_poolTimeout, m_receiveConnection, m_sendConnection, m_timeoutTime

Constructor Summary

Constructors

Constructor and Description
TopicConnector(javax.jms.TopicConnectionFactory 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 adapter, JMSURLHelper jmsurl)

Method Summary

Modifier and Type	Method and Description
protected JMSConnector.AsyncConnection	createAsyncConnection(javax.jms.ConnectionFactory factory, javax.jms.Connection connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
JMSEndpoint	createEndpoint(javax.jms.Destination destination) Create an endpoint for a queue destination.
JMSEndpoint	createEndpoint(java.lang.String destination)
protected JMSConnector.SyncConnection	createSyncConnection(javax.jms.ConnectionFactory factory, javax.jms.Connection connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)
protected javax.jms.Connection	internalConnect(javax.jms.ConnectionFactory connectionFactory, java.lang.String username, java.lang.String password)

Methods inherited from class org.apache.axis.transport.jms.JMSConnector

createConnectionWithRetry, getClientID, getConnectionFactory, getJMSURL, getNumRetries, getPassword, getUsername, getVendorAdapter, numSessions, shutdown, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TopicConnector

public TopicConnector(javax.jms.TopicConnectionFactory 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 adapter,
                      JMSURLHelper jmsurl)
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

internalConnect

protected javax.jms.Connection internalConnect(javax.jms.ConnectionFactory connectionFactory,
                                               java.lang.String username,
                                               java.lang.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,
                                                           java.lang.String threadName,
                                                           java.lang.String clientID,
                                                           java.lang.String username,
                                                           java.lang.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,
                                                             java.lang.String threadName,
                                                             java.lang.String clientID,
                                                             java.lang.String username,
                                                             java.lang.String password)
                                                      throws javax.jms.JMSException

Specified by:

createAsyncConnection in class JMSConnector

Throws:

javax.jms.JMSException

createEndpoint

public JMSEndpoint createEndpoint(java.lang.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