Package org.apache.activemq.ra

Class ActiveMQConnectionSupport

    • Field Detail

      • log

        protected org.slf4j.Logger log

    • Constructor Detail

      • ActiveMQConnectionSupport

        public ActiveMQConnectionSupport()

    • Method Detail

      • createConnectionFactory

        protected ActiveMQConnectionFactory createConnectionFactory​(ActiveMQConnectionRequestInfo connectionRequestInfo,
                                                            MessageActivationSpec activationSpec)
        Creates a factory for obtaining physical connections to an Active MQ broker. The factory is configured with the given configuration information.
        Parameters:
        connectionRequestInfo - the configuration request information
        activationSpec -
        Returns:
        the connection factory
        Throws:
        IllegalArgumentException - if the server URL given in the configuration information is not a valid URL

      • makeConnection

        public ActiveMQConnection makeConnection​(ActiveMQConnectionRequestInfo connectionRequestInfo)
                                  throws JMSException
        Creates a new physical connection to an Active MQ broker identified by given connection request information.
        Parameters:
        connectionRequestInfo - the connection request information identifying the broker and any required connection parameters, e.g. username/password
        Returns:
        the physical connection
        Throws:
        JMSException - if the connection could not be established

      • makeConnection

        public ActiveMQConnection makeConnection​(ActiveMQConnectionRequestInfo connectionRequestInfo,
                                         ActiveMQConnectionFactory connectionFactory)
                                  throws JMSException
        Creates a new physical connection to an Active MQ broker using a given connection factory and credentials supplied in connection request information.
        Parameters:
        connectionRequestInfo - the connection request information containing the credentials to use for the connection request
        Returns:
        the physical connection
        Throws:
        JMSException - if the connection could not be established

      • setInfo

        protected void setInfo​(ActiveMQConnectionRequestInfo connectionRequestInfo)
        Sets the connection request information as a whole.
        Parameters:
        connectionRequestInfo - the connection request information

      • notEqual

        protected boolean notEqual​(Object o1,
                           Object o2)

      • emptyToNull

        protected String emptyToNull​(String value)

      • getClientid

        public String getClientid()
        Returns:
        client id

      • setClientid

        public void setClientid​(String clientid)
        Parameters:
        clientid -

      • getPassword

        public String getPassword()
        Returns:
        password

      • setPassword

        public void setPassword​(String password)
        Parameters:
        password -

      • getServerUrl

        public String getServerUrl()
        Returns:
        server URL

      • setServerUrl

        public void setServerUrl​(String url)
        Parameters:
        url -

      • getTrustStore

        public String getTrustStore()

      • setTrustStore

        public void setTrustStore​(String trustStore)

      • getTrustStorePassword

        public String getTrustStorePassword()

      • setTrustStorePassword

        public void setTrustStorePassword​(String trustStorePassword)

      • getKeyStore

        public String getKeyStore()

      • setKeyStore

        public void setKeyStore​(String keyStore)

      • getKeyStorePassword

        public String getKeyStorePassword()

      • setKeyStorePassword

        public void setKeyStorePassword​(String keyStorePassword)

      • getKeyStoreKeyPassword

        public String getKeyStoreKeyPassword()

      • setKeyStoreKeyPassword

        public void setKeyStoreKeyPassword​(String keyStoreKeyPassword)

      • getUserName

        public String getUserName()
        Returns:
        user name

      • setUserName

        public void setUserName​(String userid)
        Parameters:
        userid -

      • getDurableTopicPrefetch

        public Integer getDurableTopicPrefetch()
        Returns:
        durable topic prefetch

      • setOptimizeDurableTopicPrefetch

        public void setOptimizeDurableTopicPrefetch​(Integer optimizeDurableTopicPrefetch)
        Parameters:
        optimizeDurableTopicPrefetch -

      • getOptimizeDurableTopicPrefetch

        public Integer getOptimizeDurableTopicPrefetch()
        Returns:
        durable topic prefetch

      • setDurableTopicPrefetch

        public void setDurableTopicPrefetch​(Integer durableTopicPrefetch)
        Parameters:
        durableTopicPrefetch -

      • getInitialRedeliveryDelay

        public Long getInitialRedeliveryDelay()
        Returns:
        initial redelivery delay

      • setInitialRedeliveryDelay

        public void setInitialRedeliveryDelay​(Long value)
        Parameters:
        value -

      • getMaximumRedeliveryDelay

        public Long getMaximumRedeliveryDelay()
        Returns:
        initial redelivery delay

      • setMaximumRedeliveryDelay

        public void setMaximumRedeliveryDelay​(Long value)
        Parameters:
        value -

      • getInputStreamPrefetch

        @Deprecated
public Integer getInputStreamPrefetch()
        Deprecated.
        Returns:
        input stream prefetch

      • getMaximumRedeliveries

        public Integer getMaximumRedeliveries()
        Returns:
        maximum redeliveries

      • setMaximumRedeliveries

        public void setMaximumRedeliveries​(Integer value)
        Parameters:
        value -

      • getQueueBrowserPrefetch

        public Integer getQueueBrowserPrefetch()
        Returns:
        queue browser prefetch

      • setQueueBrowserPrefetch

        public void setQueueBrowserPrefetch​(Integer queueBrowserPrefetch)
        Parameters:
        queueBrowserPrefetch -

      • getQueuePrefetch

        public Integer getQueuePrefetch()
        Returns:
        queue prefetch

      • setQueuePrefetch

        public void setQueuePrefetch​(Integer queuePrefetch)
        Parameters:
        queuePrefetch -

      • getRedeliveryBackOffMultiplier

        public Double getRedeliveryBackOffMultiplier()
        Returns:
        redelivery backoff multiplier

      • setRedeliveryBackOffMultiplier

        public void setRedeliveryBackOffMultiplier​(Double value)
        Parameters:
        value -

      • getRedeliveryUseExponentialBackOff

        public Boolean getRedeliveryUseExponentialBackOff()
        Returns:
        redelivery use exponential backoff

      • setRedeliveryUseExponentialBackOff

        public void setRedeliveryUseExponentialBackOff​(Boolean value)
        Parameters:
        value -

      • getTopicPrefetch

        public Integer getTopicPrefetch()
        Returns:
        topic prefetch

      • setTopicPrefetch

        public void setTopicPrefetch​(Integer topicPrefetch)
        Parameters:
        topicPrefetch -

      • setAllPrefetchValues

        public void setAllPrefetchValues​(Integer i)
        Parameters:
        i -

      • isUseInboundSessionEnabled

        public boolean isUseInboundSessionEnabled()
        Returns:
        use inbound session enabled

      • getUseInboundSession

        public Boolean getUseInboundSession()
        Returns:
        use inbound session

      • setUseInboundSession

        public void setUseInboundSession​(Boolean useInboundSession)
        Parameters:
        useInboundSession -

      • isUseSessionArgs

        public boolean isUseSessionArgs()

      • getUseSessionArgs

        public Boolean getUseSessionArgs()

      • setUseSessionArgs

        public void setUseSessionArgs​(Boolean useSessionArgs)
        if true, calls to managed connection factory.connection.createSession will respect the passed in args. When false (default) the args are ignored b/c the container will do transaction demarcation via xa or local transaction rar contracts. This option is useful when a managed connection is used in plain jms mode and a jms transacted session session is required.
        Parameters:
        useSessionArgs -