LocalizedQueueConnectionFactory (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.xd.dirt.integration.rabbit.LocalizedQueueConnectionFactory

実装済みのインターフェース一覧:
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
```
キューが配置されているノードを判別し、そのノードに直接接続するファクトリを返す RoutingConnectionFactory。RabbitMQ 管理プラグインは REST 経由で呼び出され、ノードを判別し、そのノードに対応するアドレスが接続ファクトリに挿入されます。各接続ファクトリのインスタンスは 1 つずつキャッシュに保持されます。場所を判別できない場合は、デフォルトの接続ファクトリが返されます。この接続ファクトリは通常、フェイルオーバーモードですべてのサーバーに接続するように構成されます。
getTargetConnectionFactory(Object) は、接続を確立するときに、'[queueName]' 形式の検索キーを使用して SimpleMessageListenerContainer によって呼び出されます。
すべての ConnectionFactory メソッドはデフォルトに委譲する
導入:
1.2
作成者:
Gary Russell, David Turanski

コンストラクター概要

コンストラクター
コンストラクターと説明
`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)`

方法の概要

メソッド
修飾子と型	メソッドと説明
`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)` アドレス専用の接続ファクトリを作成します。
`protected org.springframework.web.client.RestTemplate`	`createRestTemplate(java.lang.String adminUri)` 指定された URI の RestTemplate を作成します。
`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)`

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクターの詳細
  - 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)
```
    パラメーター:
    defaultConnectionFactory - キューが見つからない場合に使用するフォールバック接続ファクトリ。
    addresses - rabbitmq サーバーのアドレス (ホスト: ポートなど)。
    adminAddresses - rabbitmq 管理アドレス (http://host:port,...) は、アドレスと同じ長さでなければなりません。
    nodes - アドレス (rabbit@server1、...) に対応する rabbitmq ノード。
    vhost - 仮想ホスト。
    username - ユーザー名。
    password - パスワード。
    useSSL - SSL を有効にするフラグ。
    sslPropertiesLocation - SSL プロパティファイルの場所。これが設定されている場合、次のパラメーターは使用されません。
    keyStore - プロパティファイルを使用しない場合のキーストアの場所。
    keyStorePassphrase - プロパティファイルを使用しない場合のキーストアのパスフレーズ。
    trustStore - プロパティファイルを使用しない場合の信頼ストアの場所。
    truststorePassphrase - プロパティファイルを使用しない場合は、信頼ストアのパスフレーズ。
- メソッドの詳細
  - createConnection
```
public org.springframework.amqp.rabbit.connection.Connection createConnection()
                                                                       throws org.springframework.amqp.AmqpException
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の createConnection
    例外:
    org.springframework.amqp.AmqpException
  - getHost
```
public java.lang.String getHost()
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の getHost
  - getPort
```
public int getPort()
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の getPort
  - getVirtualHost
```
public java.lang.String getVirtualHost()
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の getVirtualHost
  - addConnectionListener
```
public void addConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の addConnectionListener
  - removeConnectionListener
```
public boolean removeConnectionListener(org.springframework.amqp.rabbit.connection.ConnectionListener listener)
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の removeConnectionListener
  - clearConnectionListeners
```
public void clearConnectionListeners()
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory 内の clearConnectionListeners
  - getTargetConnectionFactory
```
public org.springframework.amqp.rabbit.connection.ConnectionFactory getTargetConnectionFactory(java.lang.Object key)
```
    次で指定:
    インターフェース org.springframework.amqp.rabbit.connection.RoutingConnectionFactory 内の getTargetConnectionFactory
  - createRestTemplate
```
protected org.springframework.web.client.RestTemplate createRestTemplate(java.lang.String adminUri)
```
    指定された URI の RestTemplate を作成します。
    パラメーター:
    adminUri - URI。
    戻り値:
    テンプレート。
  - createConnectionFactory
```
protected org.springframework.amqp.rabbit.connection.ConnectionFactory createConnectionFactory(java.lang.String address)
                                                                                        throws java.lang.Exception
```
    アドレス専用の接続ファクトリを作成します。
    パラメーター:
    address - ファクトリが接続するアドレス。
    戻り値:
    接続ファクトリ。
    例外:
    java.lang.Exception - 作成中にエラーが発生した場合。

クラス LocalizedQueueConnectionFactory

コンストラクター概要

方法の概要

クラス java.lang.Object から継承されたメソッド

コンストラクターの詳細

LocalizedQueueConnectionFactory

メソッドの詳細

createConnection

getHost

getPort

getVirtualHost

addConnectionListener

removeConnectionListener

clearConnectionListeners

getTargetConnectionFactory

createRestTemplate

createConnectionFactory