クラス RabbitResourceHolder

  • 実装されたすべてのインターフェース:
    ResourceHolder

    public class RabbitResourceHolder
    extends ResourceHolderSupport
    RabbitMQ 接続とチャネルをラップする Rabbit リソースホルダー。RabbitTransactionManager は、指定された Rabbit ConnectionFactory に対して、このクラスのインスタンスをスレッドにバインドします。

    メモ: これは SPI クラスであり、アプリケーションでの使用は意図されていません。

    作成者:
    Mark Fisher, Dave Syer, Gary Russell
    関連事項:
    RabbitTransactionManager, RabbitTemplate
    • コンストラクターの詳細

      • RabbitResourceHolder

        public RabbitResourceHolder()
        リソースを追加するために開いている新しい RabbitResourceHolder を作成します。
      • RabbitResourceHolder

        public RabbitResourceHolder​(com.rabbitmq.client.Channel channel,
                                    boolean releaseAfterCompletion)
        チャネルのインスタンスを構築します。
        パラメーター:
        channel - 追加するチャンネル
        releaseAfterCompletion - 完了後にチャネルを解放する必要がある場合は true。
    • メソッドの詳細

      • isReleaseAfterCompletion

        public boolean isReleaseAfterCompletion()
        トランザクションの補完後にリソースを解放するかどうか。デフォルトは真です。リスナーは引き続きチャネルを使用するため、リスナーコンテナーは false に設定されます。
        戻り値:
        リソースを解放する必要がある場合は true。
      • setRequeueOnRollback

        public void setRequeueOnRollback​(boolean requeueOnRollback)
        ロールバック時にメッセージを再キューイングするには true に設定します。デフォルトは真です。
        パラメーター:
        requeueOnRollback - 再キューイングに真
        導入:
        1.7.1
      • addConnection

        public final void addConnection​(Connection connection)
      • addChannel

        public final void addChannel​(com.rabbitmq.client.Channel channel)
      • addChannel

        public final void addChannel​(com.rabbitmq.client.Channel channel,
                                     @Nullable
                                     Connection connection)
      • containsChannel

        public boolean containsChannel​(com.rabbitmq.client.Channel channel)
      • getChannel

        @Nullable
        public com.rabbitmq.client.Channel getChannel()
      • closeAll

        public void closeAll()
      • addDeliveryTag

        public void addDeliveryTag​(com.rabbitmq.client.Channel channel,
                                   long deliveryTag)
      • rollbackAll

        public void rollbackAll()