org.springframework.xd.dirt.integration.rabbit

Class LocalizedQueueConnectionFactory

java.lang.Object

org.springframework.xd.dirt.integration.rabbit.LocalizedQueueConnectionFactory

All Implemented Interfaces:

org.springframework.amqp.rabbit.connection.ConnectionFactory, org.springframework.amqp.rabbit.connection.RoutingConnectionFactory

public class LocalizedQueueConnectionFactory
extends java.lang.Object
implements org.springframework.amqp.rabbit.connection.ConnectionFactory, org.springframework.amqp.rabbit.connection.RoutingConnectionFactory

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, David Turanski

Constructor Summary

Constructors

Constructor and Description

LocalizedQueueConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory defaultConnectionFactory, java.lang.String[] addresses, java.lang.String[] adminAddresses, java.lang.String[] nodes, java.lang.String vhost, java.lang.String username, java.lang.String password, boolean useSSL, org.springframework.core.io.Resource sslPropertiesLocation, java.lang.String keyStore, java.lang.String keyStorePassphrase, java.lang.String trustStore, java.lang.String truststorePassphrase)

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)
void	clearConnectionListeners()
org.springframework.amqp.rabbit.connection.Connection	createConnection()
protected org.springframework.amqp.rabbit.connection.ConnectionFactory	createConnectionFactory(java.lang.String address) Create a dedicated connection factory for the address.
protected org.springframework.web.client.RestTemplate	createRestTemplate(java.lang.String adminUri) Create a RestTemplate for the supplied URI.
java.lang.String	getHost()
int	getPort()
org.springframework.amqp.rabbit.connection.ConnectionFactory	getTargetConnectionFactory(java.lang.Object key)
java.lang.String	getVirtualHost()
boolean	removeConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalizedQueueConnectionFactory

public LocalizedQueueConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory defaultConnectionFactory,
                               java.lang.String[] addresses,
                               java.lang.String[] adminAddresses,
                               java.lang.String[] nodes,
                               java.lang.String vhost,
                               java.lang.String username,
                               java.lang.String password,
                               boolean useSSL,
                               org.springframework.core.io.Resource sslPropertiesLocation,
                               java.lang.String keyStore,
                               java.lang.String keyStorePassphrase,
                               java.lang.String trustStore,
                               java.lang.String truststorePassphrase)

Parameters:

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

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

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

nodes - the rabbitmq nodes corresponding to addresses (rabbit@server1, ...).

vhost - the virtual host.

username - the user name.

password - the password.

useSSL - flag to enable SSL.

sslPropertiesLocation - location of SSL properties file. If this is set, the following parameters are not used.

keyStore - the key store location if not using properties file.

keyStorePassphrase - the key store passphrase if not using properties file.

trustStore - the trust store location if not using properties file.

truststorePassphrase - the trust store passphrase if not using properties file.

Method Detail

createConnection

public org.springframework.amqp.rabbit.connection.Connection createConnection()
                                                                       throws org.springframework.amqp.AmqpException

Specified by:

createConnection in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

Throws:

org.springframework.amqp.AmqpException

getHost

public java.lang.String getHost()

Specified by:

getHost in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getPort

public int getPort()

Specified by:

getPort in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getVirtualHost

public java.lang.String getVirtualHost()

Specified by:

getVirtualHost in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

addConnectionListener

public void addConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)

Specified by:

addConnectionListener in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

removeConnectionListener

public boolean removeConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)

Specified by:

removeConnectionListener in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

clearConnectionListeners

public void clearConnectionListeners()

Specified by:

clearConnectionListeners in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getTargetConnectionFactory

public org.springframework.amqp.rabbit.connection.ConnectionFactory getTargetConnectionFactory(java.lang.Object key)

Specified by:

getTargetConnectionFactory in interface org.springframework.amqp.rabbit.connection.RoutingConnectionFactory

createRestTemplate

protected org.springframework.web.client.RestTemplate createRestTemplate(java.lang.String adminUri)

Create a RestTemplate for the supplied URI.

Parameters:

adminUri - the URI.

Returns:

the template.

createConnectionFactory

protected org.springframework.amqp.rabbit.connection.ConnectionFactory createConnectionFactory(java.lang.String address)
                                                                                        throws java.lang.Exception

Create a dedicated connection factory for the address.

Parameters:

address - the address to which the factory should connect.

Returns:

the connection factory.

Throws:

java.lang.Exception - if errors occur during creation.