クラス ConsumerChannelRegistry

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

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    static @Nullable com.rabbitmq.client.Channel
    getConsumerChannel()
    registerConsumerChannel を参照してください。
    static @Nullable com.rabbitmq.client.Channel
    getConsumerChannel(ConnectionFactory connectionFactory)
    registerConsumerChannel を参照してください。
    static void
    registerConsumerChannel(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory)
    リスナーコンテナーが RabbitTransactionManager を使用するように構成されている場合、コンシューマーのチャネルはここに登録され、トランザクションが実際に開始されたときにバインドされたリソースとして使用されます。
    static void
    unRegisterConsumerChannel()
    registerConsumerChannel を参照してください。

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

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • メソッドの詳細

    • registerConsumerChannel

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

    • unRegisterConsumerChannel

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

    • getConsumerChannel

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

    • getConsumerChannel

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