クラス AbstractRoutingConnectionFactory
- java.lang.ObjectSE
-
- org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- 実装されたすべてのインターフェース:
ConnectionFactory
、RoutingConnectionFactory
、InitializingBean
- 既知の直属サブクラス
SimpleRoutingConnectionFactory
public abstract class AbstractRoutingConnectionFactory extends ObjectSE implements ConnectionFactory, RoutingConnectionFactory, InitializingBean
ルックアップキーに基づいて、createConnection()
呼び出しをさまざまなターゲット ConnectionFactories の 1 つにルーティングする抽象ConnectionFactory
実装。後者は、通常 (必ずしもそうとは限りませんが) スレッドにバインドされたコンテキストによって決定されます。- 導入:
- 1.3
- 作成者:
- Artem Bilan, Josh Chappelle, Gary Russell
コンストラクターのサマリー
コンストラクター コンストラクター 説明 AbstractRoutingConnectionFactory()
メソッドのサマリー
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.connection.ConnectionFactory から継承されたメソッド
getPublisherConnectionFactory, isSimplePublisherConfirms
メソッドの詳細
setTargetConnectionFactories
public void setTargetConnectionFactories(MapSE<ObjectSE,ConnectionFactory> targetConnectionFactories)
検索キーをキーとして、ターゲット ConnectionFactories のマップを指定します。キーは任意の型にすることができます。このクラスは、一般的なルックアッププロセスのみを実装します。具体的なキー表現は
determineCurrentLookupKey()
によって処理されます。- パラメーター:
targetConnectionFactories
- ターゲット接続ファクトリとルックアップキー。
setDefaultTargetConnectionFactory
public void setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory)
デフォルトのターゲットConnectionFactory
を指定します(存在する場合)。この
ConnectionFactory
は、キー付きtargetConnectionFactories
のいずれもdetermineCurrentLookupKey()
の現在のルックアップキーと一致しない場合にターゲットとして使用されます。- パラメーター:
defaultTargetConnectionFactory
- デフォルトのターゲット接続ファクトリ。
setLenientFallback
public void setLenientFallback(boolean lenientFallback)
現在のルックアップキーに対して特定のConnectionFactory
が見つからなかった場合、デフォルトのConnectionFactory
に寛大なフォールバックを適用するかどうかを指定します。デフォルトは "true" で、
targetConnectionFactories
に対応するエントリがないルックアップキーを受け入れます。その場合、単にデフォルトのConnectionFactory
にフォールバックします。ルックアップキーが
null
の場合にのみフォールバックを適用する場合は、このフラグを "false" に切り替えます。ConnectionFactory
エントリのない検索キーは、IllegalStateException
SE につながります。- パラメーター:
lenientFallback
- 指定されている場合、デフォルトにフォールバックする場合は true。- 関連事項:
setTargetConnectionFactories(java.util.Map<java.lang.Object, org.springframework.amqp.rabbit.connection.ConnectionFactory>)
,setDefaultTargetConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory)
,determineCurrentLookupKey()
isLenientFallback
public boolean isLenientFallback()
isPublisherConfirms
public boolean isPublisherConfirms()
インターフェースからコピーされた説明:ConnectionFactory
パブリッシャーの確認が有効になっている場合は true を返します。- 次で指定:
- インターフェース
ConnectionFactory
のisPublisherConfirms
- 戻り値:
- パブリッシャー確認。
isPublisherReturns
public boolean isPublisherReturns()
インターフェースからコピーされた説明:ConnectionFactory
パブリッシャーの return が有効になっている場合は true を返します。- 次で指定:
- インターフェース
ConnectionFactory
のisPublisherReturns
- 戻り値:
- パブリッシャーが return します。
afterPropertiesSet
public void afterPropertiesSet() throws ExceptionSE
- 次で指定:
- インターフェース
InitializingBean
のafterPropertiesSet
- 例外:
ExceptionSE
createConnection
public Connection createConnection() throws AmqpException
- 次で指定:
- インターフェース
ConnectionFactory
のcreateConnection
- 例外:
AmqpException
determineTargetConnectionFactory
protected ConnectionFactory determineTargetConnectionFactory()
現在のターゲットConnectionFactory
を取得します。current lookup key
を決定し、targetConnectionFactories
マップで検索を実行し、必要に応じて指定されたdefaultTargetConnectionFactory
にフォールバックします。- 戻り値:
- 接続ファクトリ。
- 関連事項:
determineCurrentLookupKey()
addConnectionListener
public void addConnectionListener(ConnectionListener listener)
- 次で指定:
- インターフェース
ConnectionFactory
のaddConnectionListener
removeConnectionListener
public boolean removeConnectionListener(ConnectionListener listener)
- 次で指定:
- インターフェース
ConnectionFactory
のremoveConnectionListener
clearConnectionListeners
public void clearConnectionListeners()
- 次で指定:
- インターフェース
ConnectionFactory
のclearConnectionListeners
getHost
public StringSE getHost()
- 次で指定:
- インターフェース
ConnectionFactory
のgetHost
getPort
public int getPort()
- 次で指定:
- インターフェース
ConnectionFactory
のgetPort
getVirtualHost
public StringSE getVirtualHost()
- 次で指定:
- インターフェース
ConnectionFactory
のgetVirtualHost
getUsername
public StringSE getUsername()
- 次で指定:
- インターフェース
ConnectionFactory
のgetUsername
getTargetConnectionFactory
public ConnectionFactory getTargetConnectionFactory(ObjectSE key)
インターフェースからコピーされた説明:RoutingConnectionFactory
指定されたルックアップキーにバインドされたConnectionFactory
を返します。存在しない場合は null を返します。- 次で指定:
- インターフェース
RoutingConnectionFactory
のgetTargetConnectionFactory
- パラメーター:
key
-ConnectionFactory
がバインドされている検索キー- 戻り値:
- 指定された検索キーにバインドされた
ConnectionFactory
、または存在しない場合は null
addTargetConnectionFactory
protected void addTargetConnectionFactory(ObjectSE key, ConnectionFactory connectionFactory)
指定されたConnectionFactory
を追加し、指定されたルックアップキーに関連付けます。- パラメーター:
key
- ルックアップキー。connectionFactory
-ConnectionFactory
removeTargetConnectionFactory
protected ConnectionFactory removeTargetConnectionFactory(ObjectSE key)
指定された検索キーに関連付けられたConnectionFactory
を削除して返します。- パラメーター:
key
- 検索キー- 戻り値:
- 取り外した
ConnectionFactory