org.apache.activemq.spring
public class ActiveMQConnectionFactoryFactoryBean extends java.lang.Object implements org.springframework.beans.factory.FactoryBean
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 and Description |
---|
ActiveMQConnectionFactoryFactoryBean() |
Modifier and Type | Method and Description |
---|---|
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"
|
protected java.lang.String |
createTcpHostAndPortUrl(java.lang.String tcpHostAndPort)
Allows us to add any TCP specific URI configurations
|
java.lang.String |
getBrokerURL() |
java.lang.String |
getFailoverProperties() |
java.lang.Long |
getMaxInactivityDuration() |
java.lang.Long |
getMaxReconnectDelay() |
java.lang.Object |
getObject() |
java.lang.Class |
getObjectType() |
java.util.List<java.lang.String> |
getTcpHostAndPorts() |
java.lang.String |
getTcpProperties() |
boolean |
isSingleton() |
protected boolean |
notEmpty(java.lang.String text) |
void |
setFailoverProperties(java.lang.String failoverProperties) |
void |
setMaxInactivityDuration(java.lang.Long maxInactivityDuration) |
void |
setMaxReconnectDelay(java.lang.Long maxReconnectDelay) |
void |
setTcpHostAndPort(java.lang.String tcpHostAndPort) |
void |
setTcpHostAndPorts(java.util.List<java.lang.String> tcpHostAndPorts) |
void |
setTcpProperties(java.lang.String tcpProperties) |
public ActiveMQConnectionFactoryFactoryBean()
public java.lang.Object getObject() throws java.lang.Exception
getObject
in interface org.springframework.beans.factory.FactoryBean
java.lang.Exception
public java.lang.String getBrokerURL()
public java.lang.Class getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean
public java.util.List<java.lang.String> getTcpHostAndPorts()
public void setTcpHostAndPorts(java.util.List<java.lang.String> tcpHostAndPorts)
public void setTcpHostAndPort(java.lang.String tcpHostAndPort)
public java.lang.Long getMaxInactivityDuration()
public void setMaxInactivityDuration(java.lang.Long maxInactivityDuration)
public java.lang.String getTcpProperties()
public void setTcpProperties(java.lang.String tcpProperties)
public java.lang.Long getMaxReconnectDelay()
public void setMaxReconnectDelay(java.lang.Long maxReconnectDelay)
public java.lang.String getFailoverProperties()
public void setFailoverProperties(java.lang.String failoverProperties)
protected java.lang.String asQueryString(java.util.List<java.lang.String> parameters)
protected java.lang.String createTcpHostAndPortUrl(java.lang.String tcpHostAndPort)
protected boolean notEmpty(java.lang.String text)
Copyright © 2005-2014. All Rights Reserved.