public abstract class AbstractRoutingConnectionFactory extends ObjectSE implements ConnectionFactory, RoutingConnectionFactory
createConnection() 呼び出しをさまざまなターゲット ConnectionFactories の 1 つにルーティングする抽象 ConnectionFactory 実装。後者は、通常 (必ずしもそうとは限りませんが) スレッドにバインドされたコンテキストによって決定されます。| コンストラクターと説明 |
|---|
AbstractRoutingConnectionFactory() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEgetPublisherConnectionFactory, isPublisherConfirms, isPublisherReturns, isSimplePublisherConfirmspublic void setTargetConnectionFactories(MapSE<ObjectSE,ConnectionFactory> targetConnectionFactories)
キーは任意の型にすることができます。このクラスは、一般的なルックアッププロセスのみを実装します。具体的なキー表現は determineCurrentLookupKey() によって処理されます。
targetConnectionFactories - ターゲット接続ファクトリとルックアップキー。public void setDefaultTargetConnectionFactory(ConnectionFactory defaultTargetConnectionFactory)
ConnectionFactory を指定します(存在する場合)。 この ConnectionFactory は、キー付き targetConnectionFactories のいずれも determineCurrentLookupKey() の現在のルックアップキーと一致しない場合にターゲットとして使用されます。
defaultTargetConnectionFactory - デフォルトのターゲット接続ファクトリ。public void setLenientFallback(boolean lenientFallback)
ConnectionFactory が見つからなかった場合、デフォルトの ConnectionFactory に寛大なフォールバックを適用するかどうかを指定します。 デフォルトは "true" で、targetConnectionFactories に対応するエントリがないルックアップキーを受け入れます。その場合、単にデフォルトの ConnectionFactory にフォールバックします。
ルックアップキーが null の場合にのみフォールバックを適用する場合は、このフラグを "false" に切り替えます。ConnectionFactory エントリのない検索キーは、IllegalStateExceptionSE につながります。
lenientFallback - 指定されている場合、デフォルトにフォールバックする場合は true。setTargetConnectionFactories(java.util.Map<java.lang.Object, org.springframework.amqp.rabbit.connection.ConnectionFactory>), setDefaultTargetConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory), determineCurrentLookupKey()public boolean isLenientFallback()
public Connection createConnection() throws AmqpException
ConnectionFactory 内の createConnection AmqpExceptionprotected ConnectionFactory determineTargetConnectionFactory()
ConnectionFactory を取得します。current lookup key を決定し、targetConnectionFactories マップで検索を実行し、必要に応じて指定された defaultTargetConnectionFactory にフォールバックします。determineCurrentLookupKey()public void addConnectionListener(ConnectionListener listener)
ConnectionFactory 内の addConnectionListener public boolean removeConnectionListener(ConnectionListener listener)
ConnectionFactory 内の removeConnectionListener public void clearConnectionListeners()
ConnectionFactory 内の clearConnectionListeners public StringSE getHost()
ConnectionFactory 内の getHost public int getPort()
ConnectionFactory 内の getPort public StringSE getVirtualHost()
ConnectionFactory 内の getVirtualHost public StringSE getUsername()
ConnectionFactory 内の getUsername public ConnectionFactory getTargetConnectionFactory(ObjectSE key)
RoutingConnectionFactoryConnectionFactory を返します。存在しない場合は null を返します。RoutingConnectionFactory 内の getTargetConnectionFactory key - ConnectionFactory がバインドされている検索キー ConnectionFactory、または存在しない場合は nullprotected void addTargetConnectionFactory(ObjectSE key, ConnectionFactory connectionFactory)
ConnectionFactory を追加し、指定されたルックアップキーに関連付けます。key - ルックアップキー。connectionFactory - ConnectionFactoryprotected ConnectionFactory removeTargetConnectionFactory(ObjectSE key)
ConnectionFactory を削除して返します。key - 検索キー ConnectionFactory