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.FactoryBeanjava.lang.Exceptionpublic java.lang.String getBrokerURL()
public java.lang.Class getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBeanpublic boolean isSingleton()
isSingleton in interface org.springframework.beans.factory.FactoryBeanpublic 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-2013 Red Hat, Inc.. All Rights Reserved.