public interface PublisherCallbackChannel
extends com.rabbitmq.client.Channel| 修飾子と型 | インターフェースと説明 |
|---|---|
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 が処理された後に呼び出されるコールバックを設定します。 |
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, waitForConfirmsOrDiestatic final StringSE RETURN_LISTENER_CORRELATION_KEY
void addListener(PublisherCallbackChannel.Listener listener)
listener - リスナー。CollectionSE<PendingConfirm> expire(PublisherCallbackChannel.Listener listener, long cutoffTime)
PendingConfirm をすべて期限切れ (削除) にして、呼び出し元に返します。listener - リスナー。cutoffTime - 期限切れのメッセージが作成される前の時間。int getPendingConfirmsCount(PublisherCallbackChannel.Listener listener)
PendingConfirm のカウントを取得します。listener - リスナー。int getPendingConfirmsCount()
void addPendingConfirm(PublisherCallbackChannel.Listener listener, long seq, PendingConfirm pendingConfirm)
listener - リスナー。seq - マップの鍵。pendingConfirm - PendingConfirm オブジェクト。com.rabbitmq.client.Channel getDelegate()
Channel のメソッドを呼び出します。Channel。void setAfterAckCallback(ConsumerSE<com.rabbitmq.client.Channel> callback)
callback - コールバック。