インターフェース 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 StringSE
RETURN_LISTENER_CORRELATION_KEY
返されたメッセージに対して呼び出すリスナーを決定するために使用されるヘッダー。static StringSE
RETURNED_MESSAGE_CORRELATION_KEY
返されたメッセージを添付する保留中の確認を見つけるために使用されるヘッダー。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 修飾子と型 メソッド 説明 void
addListener(PublisherCallbackChannel.Listener 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
メソッドの詳細
addListener
void addListener(PublisherCallbackChannel.Listener 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