インターフェース 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 final StringSE
    RETURN_LISTENER_CORRELATION_KEY
    返されたメッセージに対して呼び出すリスナーを決定するために使用されるヘッダー。
    static final StringSE
    RETURNED_MESSAGE_CORRELATION_KEY
    返されたメッセージを添付する保留中の確認を見つけるために使用されるヘッダー。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    addListener(PublisherCallbackChannel.Listener listener)
    PublisherCallbackChannel.Listener を追加します。
    void
    addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
    保留中の確認をこのチャネルのマップに追加します。
    CollectionSE<PendingConfirm>
    expire(PublisherCallbackChannel.Listener listener, long cutoffTime)
    指定されたリスナーの cutoffTime より前に作成された PendingConfirm をすべて期限切れ (削除) にして、呼び出し元に返します。
    com.rabbitmq.client.Channel
    getDelegate()
    これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアント Channel のメソッドを呼び出します。
    int
    getPendingConfirmsCount()
    保留中の合計確認数を取得します。
    int
    getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
    PendingConfirm のカウントを取得します。
    void
    setAfterAckCallback(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
      返されたメッセージを添付する保留中の確認を見つけるために使用されるヘッダー。
      関連事項:

  • メソッドの詳細

    • addListener

      void addListener(PublisherCallbackChannel.Listener listener)
      PublisherCallbackChannel.Listener を追加します。
      パラメーター:
      listener - リスナー。

    • 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