パッケージ org.springframework.amqp.rabbit.connection

クラス ConsumerChannelRegistry

  • public final class ConsumerChannelRegistry
extends ObjectSE
    コンシューマーは、プライマリチャネルをこのクラスに登録します。これは、トランザクションを使用するときに、リソースホルダーがコンシューマーによって使用されているプライマリチャネルを閉じないようにするために使用されます。これは以前は ConnectionFactoryUtils にありましたが、RabbitResourceHolder でクラスのもつれが発生しました。
    導入:
    1.2
    作成者:
    Gary Russell

    • メソッドの詳細

      • registerConsumerChannel

        public static void registerConsumerChannel​(com.rabbitmq.client.Channel channel,
                                           ConnectionFactory connectionFactory)
        リスナーコンテナーが RabbitTransactionManager を使用するように構成されている場合、コンシューマーのチャネルはここに登録され、トランザクションが実際に開始されたときにバインドされたリソースとして使用されます。ローカルトランザクションはチャネルがスレッドにバインドされているという点で同じように機能するため、通常は外部トランザクションマネージャーを使用する必要はありません。これは、ユーザーがたまたま RabbitTransactionManager を接続した場合です。
        パラメーター:
        channel - 登録するチャネル。
        connectionFactory - 接続ファクトリ。

      • unRegisterConsumerChannel

        public static void unRegisterConsumerChannel()
        registerConsumerChannel を参照してください。このメソッドは、コンシューマーが終了するときにチャネルを登録解除するために呼び出されます。

      • getConsumerChannel

        @Nullable
public static com.rabbitmq.client.Channel getConsumerChannel()
        registerConsumerChannel を参照してください。このメソッドは、このコンシューマーのチャネルを取得するために呼び出されます。
        戻り値:
        チャンネル。

      • getConsumerChannel

        @Nullable
public static com.rabbitmq.client.Channel getConsumerChannel​(ConnectionFactory connectionFactory)
        registerConsumerChannel を参照してください。このメソッドは、接続ファクトリが一致する場合に、このコンシューマーのチャネルを取得するために呼び出されます。
        パラメーター:
        connectionFactory - 接続ファクトリ。
        戻り値:
        チャンネル。