Package org.apache.activemq.spring

Class ActiveMQConnectionFactoryFactoryBean

  • All Implemented Interfaces:
    org.springframework.beans.factory.FactoryBean
    public class ActiveMQConnectionFactoryFactoryBean
extends Object
implements org.springframework.beans.factory.FactoryBean
    A helper class for creating a failover configured ActiveMQConnectionFactory which supports one or more TCP based hostname/ports which can all be configured in a consistent way without too much URL hacking.

    • Constructor Detail

      • ActiveMQConnectionFactoryFactoryBean

        public ActiveMQConnectionFactoryFactoryBean()

    • Method Detail

      • getObject

        public Object getObject()
                 throws Exception
        Specified by:
        getObject in interface org.springframework.beans.factory.FactoryBean
        Throws:
        Exception

      • getBrokerURL

        public String getBrokerURL()

      • getObjectType

        public Class getObjectType()
        Specified by:
        getObjectType in interface org.springframework.beans.factory.FactoryBean

      • isSingleton

        public boolean isSingleton()
        Specified by:
        isSingleton in interface org.springframework.beans.factory.FactoryBean

      • getTcpHostAndPorts

        public List<String> getTcpHostAndPorts()

      • setTcpHostAndPorts

        public void setTcpHostAndPorts​(List<String> tcpHostAndPorts)

      • setTcpHostAndPort

        public void setTcpHostAndPort​(String tcpHostAndPort)

      • getMaxInactivityDuration

        public Long getMaxInactivityDuration()

      • setMaxInactivityDuration

        public void setMaxInactivityDuration​(Long maxInactivityDuration)

      • getTcpProperties

        public String getTcpProperties()

      • setTcpProperties

        public void setTcpProperties​(String tcpProperties)

      • getMaxReconnectDelay

        public Long getMaxReconnectDelay()

      • setMaxReconnectDelay

        public void setMaxReconnectDelay​(Long maxReconnectDelay)

      • getFailoverProperties

        public String getFailoverProperties()

      • setFailoverProperties

        public void setFailoverProperties​(String failoverProperties)

      • asQueryString

        protected String asQueryString​(List<String> parameters)
        Turns a list of query string key=value strings into a query URL string of the form "?a=x&b=y"

      • createTcpHostAndPortUrl

        protected String createTcpHostAndPortUrl​(String tcpHostAndPort)
        Allows us to add any TCP specific URI configurations

      • notEmpty

        protected boolean notEmpty​(String text)