Class 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 Detail

      • TopicConnector

        public TopicConnector​(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 JMSException
        Throws:
        JMSException
    • Method Detail

      • internalConnect

        protected Connection internalConnect​(ConnectionFactory connectionFactory,
                                             java.lang.String username,
                                             java.lang.String password)
                                      throws JMSException
        Specified by:
        internalConnect in class JMSConnector
        Throws:
        JMSException
      • createSyncConnection

        protected JMSConnector.SyncConnection createSyncConnection​(ConnectionFactory factory,
                                                                   Connection connection,
                                                                   int numSessions,
                                                                   java.lang.String threadName,
                                                                   java.lang.String clientID,
                                                                   java.lang.String username,
                                                                   java.lang.String password)
                                                            throws JMSException
        Specified by:
        createSyncConnection in class JMSConnector
        Throws:
        JMSException
      • createAsyncConnection

        protected JMSConnector.AsyncConnection createAsyncConnection​(ConnectionFactory factory,
                                                                     Connection connection,
                                                                     java.lang.String threadName,
                                                                     java.lang.String clientID,
                                                                     java.lang.String username,
                                                                     java.lang.String password)
                                                              throws JMSException
        Specified by:
        createAsyncConnection in class JMSConnector
        Throws:
        JMSException
      • createEndpoint

        public JMSEndpoint createEndpoint​(Destination destination)
                                   throws JMSException
        Create an endpoint for a queue destination.
        Specified by:
        createEndpoint in class JMSConnector
        Parameters:
        destination -
        Returns:
        Throws:
        JMSException