インターフェース 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
このインターフェースを実装するリスナーは、各チャネルで addListener を呼び出すことにより、複数のチャネルから受信したパブリッシャーの確認に参加できます。フィールドサマリー
フィールドメソッドのサマリー
修飾子と型メソッド説明void
addListener
(PublisherCallbackChannel.Listener listener) void
addPendingConfirm
(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm) 保留中の確認をこのチャネルのマップに追加します。expire
(PublisherCallbackChannel.Listener listener, long cutoffTime) 指定されたリスナーの cutoffTime より前に作成されたPendingConfirm
を期限切れ (削除) し、呼び出し元に返します。com.rabbitmq.client.Channel
これを使用して、この実装ではサポートされていない、基礎となる rabbit クライアントChannel
のメソッドを呼び出します。int
保留中の合計確認数を取得します。int
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
フィールドの詳細
メソッドの詳細
addListener
- パラメーター:
listener
- リスナー。
expire
指定されたリスナーの cutoffTime より前に作成されたPendingConfirm
を期限切れ (削除) し、呼び出し元に返します。- パラメーター:
listener
- リスナー。cutoffTime
- 期限切れのメッセージが作成される前の時間。- 戻り値:
- 期限切れの確認のリスト。
getPendingConfirmsCount
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
ack/nack が処理された後に呼び出されるコールバックを設定します。- パラメーター:
callback
- コールバック。- 導入:
- 2.1