クラス ConsumerChannelRegistry
java.lang.ObjectSE
org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
コンシューマーは、プライマリチャネルをこのクラスに登録します。これは、トランザクションを使用するときに、リソースホルダーがコンシューマーによって使用されているプライマリチャネルを閉じないようにするために使用されます。これは以前は ConnectionFactoryUtils にありましたが、RabbitResourceHolder でクラスのもつれが発生しました。
- 導入:
- 1.2
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明static com.rabbitmq.client.Channel
registerConsumerChannel を参照してください。static com.rabbitmq.client.Channel
getConsumerChannel
(ConnectionFactory connectionFactory) registerConsumerChannel を参照してください。static void
registerConsumerChannel
(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) リスナーコンテナーが RabbitTransactionManager を使用するように構成されている場合、コンシューマーのチャネルはここに登録され、トランザクションが実際に開始されたときにバインドされたリソースとして使用されます。static void
registerConsumerChannel を参照してください。
メソッドの詳細
registerConsumerChannel
public static void registerConsumerChannel(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory) リスナーコンテナーが RabbitTransactionManager を使用するように構成されている場合、コンシューマーのチャネルはここに登録され、トランザクションが実際に開始されたときにバインドされたリソースとして使用されます。ローカルトランザクションはチャネルがスレッドにバインドされているという点で同じように機能するため、通常は外部トランザクションマネージャーを使用する必要はありません。これは、ユーザーがたまたま RabbitTransactionManager を接続した場合です。- パラメーター:
channel
- 登録するチャネル。connectionFactory
- 接続ファクトリ。
unRegisterConsumerChannel
public static void unRegisterConsumerChannel()registerConsumerChannel を参照してください。このメソッドは、コンシューマーが終了したときにチャネルを登録解除するために呼び出されます。getConsumerChannel
registerConsumerChannel を参照してください。このメソッドは、このコンシューマーのチャネルを取得するために呼び出されます。- 戻り値:
- チャンネル。
getConsumerChannel
@Nullable public static com.rabbitmq.client.Channel getConsumerChannel(ConnectionFactory connectionFactory) registerConsumerChannel を参照してください。このメソッドは、接続ファクトリが一致する場合に、このコンシューマーのチャネルを取得するために呼び出されます。- パラメーター:
connectionFactory
- 接続ファクトリ。- 戻り値:
- チャンネル。