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 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 Summary

Constructors

Constructor and Description
ActiveMQConnectionFactoryFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
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"
protected String	createTcpHostAndPortUrl(String tcpHostAndPort) Allows us to add any TCP specific URI configurations
String	getBrokerURL()
String	getFailoverProperties()
Long	getMaxInactivityDuration()
Long	getMaxReconnectDelay()
Object	getObject()
Class	getObjectType()
List<String>	getTcpHostAndPorts()
String	getTcpProperties()
boolean	isSingleton()
protected boolean	notEmpty(String text)
void	setFailoverProperties(String failoverProperties)
void	setMaxInactivityDuration(Long maxInactivityDuration)
void	setMaxReconnectDelay(Long maxReconnectDelay)
void	setTcpHostAndPort(String tcpHostAndPort)
void	setTcpHostAndPorts(List<String> tcpHostAndPorts)
void	setTcpProperties(String tcpProperties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)