org.springframework.amqp.rabbit.connection

Class AbstractRoutingConnectionFactory

java.lang.Object

org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory

All Implemented Interfaces:

ConnectionFactory

Direct Known Subclasses:

SimpleRoutingConnectionFactory

public abstract class AbstractRoutingConnectionFactory
extends Object
implements ConnectionFactory

Abstract ConnectionFactory implementation that routes createConnection() calls to one of various target ConnectionFactories based on a lookup key. The latter is usually (but not necessarily) determined through some thread-bound context.

Since:

1.3

Author:

Artem Bilan, Josh Chappelle

Constructor Summary

Constructors

Constructor and Description
AbstractRoutingConnectionFactory()

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener)
protected void	addTargetConnectionFactory(Object key, ConnectionFactory connectionFactory) Adds the given ConnectionFactory and associates it with the given lookup key
void	clearConnectionListeners()
Connection	createConnection()
protected abstract Object	determineCurrentLookupKey() Determine the current lookup key.
protected ConnectionFactory	determineTargetConnectionFactory() Retrieve the current target ConnectionFactory.
String	getHost()
int	getPort()
protected ConnectionFactory	getTargetConnectionFactory(Object key) Returns the ConnectionFactory bound to given lookup key, null if one does not exist
String	getVirtualHost()
boolean	removeConnectionListener(ConnectionListener listener)
protected ConnectionFactory	removeTargetConnectionFactory(Object key) Removes the ConnectionFactory associated with the given lookup key and returns it.
void	setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory) Specify the default target ConnectionFactory, if any.
void	setLenientFallback(boolean lenientFallback) Specify whether to apply a lenient fallback to the default ConnectionFactory if no specific ConnectionFactory could be found for the current lookup key.
void	setTargetConnectionFactories(Map<Object,ConnectionFactory> targetConnectionFactories) Specify the map of target ConnectionFactories, with the lookup key as key.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractRoutingConnectionFactory

public AbstractRoutingConnectionFactory()

Method Detail

setTargetConnectionFactories

public void setTargetConnectionFactories(Map<Object,ConnectionFactory> targetConnectionFactories)

Specify the map of target ConnectionFactories, with the lookup key as key.

The key can be of arbitrary type; this class implements the generic lookup process only. The concrete key representation will be handled by determineCurrentLookupKey().

Parameters:

targetConnectionFactories - The target connection factories and lookup keys.

setDefaultTargetConnectionFactory

public void setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory)

Specify the default target ConnectionFactory, if any.

This ConnectionFactory will be used as target if none of the keyed targetConnectionFactories match the determineCurrentLookupKey() current lookup key.

Parameters:

defaultTargetConnectionFactory - The default target connection factory.

setLenientFallback

public void setLenientFallback(boolean lenientFallback)

Specify whether to apply a lenient fallback to the default ConnectionFactory if no specific ConnectionFactory could be found for the current lookup key.

Default is "true", accepting lookup keys without a corresponding entry in the targetConnectionFactories - simply falling back to the default ConnectionFactory in that case.

Switch this flag to "false" if you would prefer the fallback to only apply if the lookup key was null. Lookup keys without a ConnectionFactory entry will then lead to an IllegalStateException.

Parameters:

lenientFallback - true to fall back to the default, if specified.

See Also:

setTargetConnectionFactories(java.util.Map<java.lang.Object, org.springframework.amqp.rabbit.connection.ConnectionFactory>), setDefaultTargetConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory), determineCurrentLookupKey()

createConnection

public Connection createConnection()
                            throws AmqpException

Specified by:

createConnection in interface ConnectionFactory

Throws:

AmqpException

determineTargetConnectionFactory

protected ConnectionFactory determineTargetConnectionFactory()

Retrieve the current target ConnectionFactory. Determines the current lookup key, performs a lookup in the targetConnectionFactories map, falls back to the specified defaultTargetConnectionFactory if necessary.

Returns:

The connection factory.

See Also:

determineCurrentLookupKey()

addConnectionListener

public void addConnectionListener(ConnectionListener listener)

Specified by:

addConnectionListener in interface ConnectionFactory

removeConnectionListener

public boolean removeConnectionListener(ConnectionListener listener)

Specified by:

removeConnectionListener in interface ConnectionFactory

clearConnectionListeners

public void clearConnectionListeners()

Specified by:

clearConnectionListeners in interface ConnectionFactory

getHost

public String getHost()

Specified by:

getHost in interface ConnectionFactory

getPort

public int getPort()

Specified by:

getPort in interface ConnectionFactory

getVirtualHost

public String getVirtualHost()

Specified by:

getVirtualHost in interface ConnectionFactory

getTargetConnectionFactory

protected ConnectionFactory getTargetConnectionFactory(Object key)

Returns the ConnectionFactory bound to given lookup key, null if one does not exist

Parameters:

key - The lookup key of which the ConnectionFactory is bound

Returns:

the ConnectionFactory bound to given lookup key, null if one does not exist

addTargetConnectionFactory

protected void addTargetConnectionFactory(Object key,
                                          ConnectionFactory connectionFactory)

Adds the given ConnectionFactory and associates it with the given lookup key

Parameters:

key - the lookup key

connectionFactory - the ConnectionFactory

removeTargetConnectionFactory

protected ConnectionFactory removeTargetConnectionFactory(Object key)

Removes the ConnectionFactory associated with the given lookup key and returns it.

Parameters:

key - the lookup key

Returns:

the ConnectionFactory that was removed

determineCurrentLookupKey

protected abstract Object determineCurrentLookupKey()

Determine the current lookup key. This will typically be implemented to check a thread-bound context.

Returns:

The lookup key.