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

インターフェース PublisherCallbackChannel

  • すべてのスーパーインターフェース:
    AutoCloseableSE、com.rabbitmq.client.Channel、com.rabbitmq.client.ShutdownNotifier
    すべての既知の実装クラス:
    PublisherCallbackChannelImpl
    public interface PublisherCallbackChannel
extends com.rabbitmq.client.Channel
    このインターフェースのインスタンスは、コールバックにコンテキストを追加することにより、複数のチャネルでパブリッシャーが確認するために登録されている単一のリスナーをサポートします。
    導入:
    1.0.1
    作成者:
    Gary Russell

    • ネストされたクラスの概要

      ネストされたクラス  
      修飾子と型 インターフェース 説明
      static interface PublisherCallbackChannel.Listener
      このインターフェースを実装するリスナーは、各チャネルで addListener を呼び出すことによって、複数のチャネルから受信したパブリッシャー確認に参加できます。

    • フィールド概要

      フィールド  
      修飾子と型 フィールド 説明
      static StringSERETURN_LISTENER_CORRELATION_KEY
      返されたメッセージに対して呼び出すリスナーを決定するために使用されるヘッダー。
      static StringSERETURNED_MESSAGE_CORRELATION_KEY
      返されたメッセージを添付する保留中の確認を見つけるために使用されるヘッダー。

    • 方法の概要

      すべてのメソッド   インスタンスメソッド   抽象メソッド  
      修飾子と型 メソッド 説明
      voidaddListener​(PublisherCallbackChannel.Listener listener)
      PublisherCallbackChannel.Listener を追加します。
      voidaddPendingConfirm​(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
      保留中の確認をこのチャネルのマップに追加します。
      CollectionSE<PendingConfirm>expire​(PublisherCallbackChannel.Listener listener, long cutoffTime)
      指定されたリスナーの cutoffTime より前に作成された PendingConfirm をすべて期限切れ (削除) にして、呼び出し元に返します。
      com.rabbitmq.client.ChannelgetDelegate()
      これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアント Channel のメソッドを呼び出します。
      intgetPendingConfirmsCount()
      保留中の合計確認数を取得します。
      intgetPendingConfirmsCount​(PublisherCallbackChannel.Listener listener)
      PendingConfirm のカウントを取得します。
      voidsetAfterAckCallback​(ConsumerSE<com.rabbitmq.client.Channel> callback)
      ack/nack が処理された後に呼び出されるコールバックを設定します。

      • インターフェース com.rabbitmq.client.Channel から継承されたメソッド

        abort, abort, addConfirmListener, addConfirmListener, addReturnListener, addReturnListener, asyncCompletableRpc, asyncRpc, basicAck, basicCancel, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicConsume, basicGet, basicNack, basicPublish, basicPublish, basicPublish, basicQos, basicQos, basicQos, basicRecover, basicRecover, basicReject, clearConfirmListeners, clearReturnListeners, close, close, confirmSelect, consumerCount, exchangeBind, exchangeBind, exchangeBindNoWait, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclare, exchangeDeclareNoWait, exchangeDeclareNoWait, exchangeDeclarePassive, exchangeDelete, exchangeDelete, exchangeDeleteNoWait, exchangeUnbind, exchangeUnbind, exchangeUnbindNoWait, getChannelNumber, getConnection, getDefaultConsumer, getNextPublishSeqNo, messageCount, queueBind, queueBind, queueBindNoWait, queueDeclare, queueDeclare, queueDeclareNoWait, queueDeclarePassive, queueDelete, queueDelete, queueDeleteNoWait, queuePurge, queueUnbind, queueUnbind, removeConfirmListener, removeReturnListener, rpc, setDefaultConsumer, txCommit, txRollback, txSelect, waitForConfirms, waitForConfirms, waitForConfirmsOrDie, waitForConfirmsOrDie

      • インターフェース com.rabbitmq.client.ShutdownNotifier から継承されたメソッド

        addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener

    • フィールドの詳細

      • RETURN_LISTENER_CORRELATION_KEY

        static final StringSE RETURN_LISTENER_CORRELATION_KEY
        返されたメッセージに対して呼び出すリスナーを決定するために使用されるヘッダー。
        関連事項:
        定数フィールド値

      • RETURNED_MESSAGE_CORRELATION_KEY

        static final StringSE RETURNED_MESSAGE_CORRELATION_KEY
        返されたメッセージを添付する保留中の確認を見つけるために使用されるヘッダー。
        関連事項:
        定数フィールド値

    • メソッドの詳細

      • expire

        CollectionSE<PendingConfirm> expire​(PublisherCallbackChannel.Listener listener,
                                  long cutoffTime)
        指定されたリスナーの cutoffTime より前に作成された PendingConfirm をすべて期限切れ (削除) にして、呼び出し元に返します。
        パラメーター:
        listener - リスナー。
        cutoffTime - 期限切れのメッセージが作成される前の時間。
        戻り値:
        期限切れの確認のリスト。

      • getPendingConfirmsCount

        int getPendingConfirmsCount​(PublisherCallbackChannel.Listener listener)
        PendingConfirm のカウントを取得します。
        パラメーター:
        listener - リスナー。
        戻り値:
        保留中の確認の数。

      • getPendingConfirmsCount

        int getPendingConfirmsCount()
        保留中の合計確認数を取得します。
        戻り値:
        カウント。
        導入:
        2.1

      • addPendingConfirm

        void addPendingConfirm​(PublisherCallbackChannel.Listener listener,
                       long seq,
                       PendingConfirm pendingConfirm)
        保留中の確認をこのチャネルのマップに追加します。
        パラメーター:
        listener - リスナー。
        seq - マップの鍵。
        pendingConfirm - PendingConfirm オブジェクト。

      • getDelegate

        com.rabbitmq.client.Channel getDelegate()
        これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアント Channel のメソッドを呼び出します。
        戻り値:
        基盤となる rabbit クライアント Channel。
        導入:
        1.4.

      • setAfterAckCallback

        void setAfterAckCallback​(ConsumerSE<com.rabbitmq.client.Channel> callback)
        ack/nack が処理された後に呼び出されるコールバックを設定します。
        パラメーター:
        callback - コールバック。
        導入:
        2.1