Package org.apache.axis.transport.jms

Class QueueConnector

  • public class QueueConnector
extends JMSConnector
    QueueConnector is a concrete JMSConnector subclass that specifically handles connections to queues (ptp domain).
    Author:
    Jaime Meritt (jmeritt@sonicsoftware.com), Richard Chung (rchung@sonicsoftware.com), Dave Chappell (chappell@sonicsoftware.com)

    • Constructor Detail

      • QueueConnector

        public QueueConnector​(ConnectionFactory 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

      • 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

      • 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