public static class AmqpMessageSource.AmqpAckCallback extends ObjectSE implements AcknowledgmentCallback
AcknowledgmentCallback.Status| コンストラクターと説明 |
|---|
AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | acknowledge(AcknowledgmentCallback.Status status) メッセージを確認します。 |
protected AmqpMessageSource.AmqpAckInfo | getAckInfo() |
boolean | isAcknowledged() フレームワークが必要に応じて自動確認できるように、実装はこれを実装してユーザーが確認を処理したことを示す必要があります。 |
boolean | isAutoAck() アプリケーションによってまだ確認されていない場合に、この確認が自動確認をサポートする場合は true を返します。 |
void | noAutoAck()SourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。 |
protected void | setAcknowledged(boolean acknowledged) |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEacknowledgepublic AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo)
protected AmqpMessageSource.AmqpAckInfo getAckInfo()
protected void setAcknowledged(boolean acknowledged)
public boolean isAcknowledged()
AcknowledgmentCallbackAcknowledgmentCallback の isAcknowledged public void noAutoAck()
AcknowledgmentCallbackSourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。すべての実装がこれをサポートしているわけではありません - たとえば、Kafka メッセージソース。AcknowledgmentCallback の noAutoAck public boolean isAutoAck()
AcknowledgmentCallbackAcknowledgmentCallback の isAutoAck public void acknowledge(AcknowledgmentCallback.Status status)
AcknowledgmentCallbackAcknowledgmentCallback の acknowledge status - ステータス。public StringSE toString()
ObjectSE の toStringSE