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

Nested Class Summary

Nested classes 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
`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
`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

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`

Copyright © 2005 Apache Web Services Project. All Rights Reserved.