org.springframework.amqp.rabbit.connection

Class LocalizedQueueConnectionFactory

java.lang.Object

org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory

All Implemented Interfaces:

ConnectionFactory, RoutingConnectionFactory, DisposableBean

public class LocalizedQueueConnectionFactory
extends Object
implements ConnectionFactory, RoutingConnectionFactory, DisposableBean

A RoutingConnectionFactory that determines the node on which a queue is located and returns a factory that connects directly to that node. The RabbitMQ management plugin is called over REST to determine the node and the corresponding address for that node is injected into the connection factory. A single instance of each connection factory is retained in a cache. If the location cannot be determined, the default connection factory is returned. This connection factory is typically configured to connect to all the servers in a fail-over mode.

getTargetConnectionFactory(Object) is invoked by the SimpleMessageListenerContainer, when establishing a connection, with the lookup key having the format '[queueName]'.

All ConnectionFactory methods delegate to the default

Since:

1.2

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, Map<String,String> nodeToAddress, String[] adminUris, String vhost, String username, String password, boolean useSSL, Resource sslPropertiesLocation)
LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, Map<String,String> nodeToAddress, String[] adminUris, String vhost, String username, String password, boolean useSSL, String keyStore, String trustStore, String keyStorePassPhrase, String trustStorePassPhrase)
LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, String[] addresses, String[] adminUris, String[] nodes, String vhost, String username, String password, boolean useSSL, Resource sslPropertiesLocation)
LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory, String[] addresses, String[] adminUris, String[] nodes, String vhost, String username, String password, boolean useSSL, String keyStore, String trustStore, String keyStorePassPhrase, String trustStorePassPhrase)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener)
void	clearConnectionListeners()
protected com.rabbitmq.http.client.Client	createClient(String adminUri, String username, String password) Create a client instance.
Connection	createConnection()
protected ConnectionFactory	createConnectionFactory(String address, String node) Create a dedicated connection factory for the address.
void	destroy()
String	getHost()
int	getPort()
ConnectionFactory	getTargetConnectionFactory(Object key) Returns the ConnectionFactory bound to given lookup key, or null if one does not exist.
String	getUsername()
String	getVirtualHost()
boolean	removeConnectionListener(ConnectionListener listener)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getPublisherConnectionFactory, isPublisherConfirms, isPublisherReturns, isSimplePublisherConfirms

Constructor Detail

LocalizedQueueConnectionFactory

public LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory,
                                       Map<String,String> nodeToAddress,
                                       String[] adminUris,
                                       String vhost,
                                       String username,
                                       String password,
                                       boolean useSSL,
                                       Resource sslPropertiesLocation)

Parameters:

defaultConnectionFactory - the fallback connection factory to use if the queue can't be located.

nodeToAddress - a Map of node to address: (rabbit@server1 : server1:5672)

adminUris - the rabbitmq admin addresses (https://host:port, ...) must be the same length as addresses.

vhost - the virtual host.

username - the user name.

password - the password.

useSSL - use SSL.

sslPropertiesLocation - the SSL properties location.

LocalizedQueueConnectionFactory

public LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory,
                                       Map<String,String> nodeToAddress,
                                       String[] adminUris,
                                       String vhost,
                                       String username,
                                       String password,
                                       boolean useSSL,
                                       String keyStore,
                                       String trustStore,
                                       String keyStorePassPhrase,
                                       String trustStorePassPhrase)

Parameters:

defaultConnectionFactory - the fallback connection factory to use if the queue can't be located.

nodeToAddress - a Map of node to address: (rabbit@server1 : server1:5672)

adminUris - the rabbitmq admin addresses (https://host:port, ...) must be the same length as addresses.

vhost - the virtual host.

username - the user name.

password - the password.

useSSL - use SSL.

keyStore - the key store resource (e.g. "file:/foo/keystore").

trustStore - the trust store resource (e.g. "file:/foo/truststore").

keyStorePassPhrase - the pass phrase for the key store.

trustStorePassPhrase - the pass phrase for the trust store.

LocalizedQueueConnectionFactory

public LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory,
                                       String[] addresses,
                                       String[] adminUris,
                                       String[] nodes,
                                       String vhost,
                                       String username,
                                       String password,
                                       boolean useSSL,
                                       @Nullable
                                       Resource sslPropertiesLocation)

Parameters:

defaultConnectionFactory - the fallback connection factory to use if the queue can't be located.

addresses - the rabbitmq server addresses (host:port, ...).

adminUris - the rabbitmq admin addresses (https://host:port, ...)

nodes - the rabbitmq nodes corresponding to addresses (rabbit@server1, ...) must be the same length as addresses.

vhost - the virtual host.

username - the user name.

password - the password.

useSSL - use SSL.

sslPropertiesLocation - the SSL properties location.

LocalizedQueueConnectionFactory

public LocalizedQueueConnectionFactory(ConnectionFactory defaultConnectionFactory,
                                       String[] addresses,
                                       String[] adminUris,
                                       String[] nodes,
                                       String vhost,
                                       String username,
                                       String password,
                                       boolean useSSL,
                                       String keyStore,
                                       String trustStore,
                                       String keyStorePassPhrase,
                                       String trustStorePassPhrase)

Parameters:

defaultConnectionFactory - the fallback connection factory to use if the queue can't be located.

addresses - the rabbitmq server addresses (host:port, ...).

adminUris - the rabbitmq admin addresses (https://host:port, ...).

nodes - the rabbitmq nodes corresponding to addresses (rabbit@server1, ...) must be the same length as addresses.

vhost - the virtual host.

username - the user name.

password - the password.

useSSL - use SSL.

keyStore - the key store resource (e.g. "file:/foo/keystore").

trustStore - the trust store resource (e.g. "file:/foo/truststore").

keyStorePassPhrase - the pass phrase for the key store.

trustStorePassPhrase - the pass phrase for the trust store.

Method Detail

createConnection

public Connection createConnection()
                            throws AmqpException

Specified by:

createConnection in interface ConnectionFactory

Throws:

AmqpException

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

getUsername

public String getUsername()

Specified by:

getUsername in interface ConnectionFactory

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

getTargetConnectionFactory

public ConnectionFactory getTargetConnectionFactory(Object key)

Description copied from interface: RoutingConnectionFactory

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

Specified by:

getTargetConnectionFactory in interface RoutingConnectionFactory

Parameters:

key - The lookup key to which the ConnectionFactory is bound

Returns:

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

createClient

protected com.rabbitmq.http.client.Client createClient(String adminUri,
                                                       String username,
                                                       String password)
                                                throws MalformedURLException,
                                                       URISyntaxException

Create a client instance.

Parameters:

adminUri - the admin URI.

username - the username

password - the password.

Returns:

The client.

Throws:

MalformedURLException - if the URL is malformed

URISyntaxException - if there is a syntax error.

createConnectionFactory

protected ConnectionFactory createConnectionFactory(String address,
                                                    String node)

Create a dedicated connection factory for the address.

Parameters:

address - the address to which the factory should connect.

node - the node.

Returns:

the connection factory.

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean