org.apache.activemq.spring
Class ActiveMQConnectionFactoryFactoryBean
java.lang.Object
org.apache.activemq.spring.ActiveMQConnectionFactoryFactoryBean
- All Implemented Interfaces:
- org.springframework.beans.factory.FactoryBean
public class ActiveMQConnectionFactoryFactoryBean
- extends java.lang.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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQConnectionFactoryFactoryBean
public ActiveMQConnectionFactoryFactoryBean()
getObject
public java.lang.Object getObject()
throws java.lang.Exception
- Specified by:
getObject
in interface org.springframework.beans.factory.FactoryBean
- Throws:
java.lang.Exception
getBrokerURL
public java.lang.String getBrokerURL()
getObjectType
public java.lang.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 java.util.List<java.lang.String> getTcpHostAndPorts()
setTcpHostAndPorts
public void setTcpHostAndPorts(java.util.List<java.lang.String> tcpHostAndPorts)
setTcpHostAndPort
public void setTcpHostAndPort(java.lang.String tcpHostAndPort)
getMaxInactivityDuration
public java.lang.Long getMaxInactivityDuration()
setMaxInactivityDuration
public void setMaxInactivityDuration(java.lang.Long maxInactivityDuration)
getTcpProperties
public java.lang.String getTcpProperties()
setTcpProperties
public void setTcpProperties(java.lang.String tcpProperties)
getMaxReconnectDelay
public java.lang.Long getMaxReconnectDelay()
setMaxReconnectDelay
public void setMaxReconnectDelay(java.lang.Long maxReconnectDelay)
getFailoverProperties
public java.lang.String getFailoverProperties()
setFailoverProperties
public void setFailoverProperties(java.lang.String failoverProperties)
asQueryString
protected java.lang.String asQueryString(java.util.List<java.lang.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 java.lang.String createTcpHostAndPortUrl(java.lang.String tcpHostAndPort)
- Allows us to add any TCP specific URI configurations
notEmpty
protected boolean notEmpty(java.lang.String text)
Copyright © 2005-2016. All Rights Reserved.