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, waitSE
acknowledge
public AmqpAckCallback(AmqpMessageSource.AmqpAckInfo ackInfo)
protected AmqpMessageSource.AmqpAckInfo getAckInfo()
protected void setAcknowledged(boolean acknowledged)
public boolean isAcknowledged()
AcknowledgmentCallback
AcknowledgmentCallback
の isAcknowledged
public void noAutoAck()
AcknowledgmentCallback
SourcePollingChannelAdapter
または MessageSourcePollingTemplate
による自動確認を無効にします。すべての実装がこれをサポートしているわけではありません - たとえば、Kafka メッセージソース。AcknowledgmentCallback
の noAutoAck
public boolean isAutoAck()
AcknowledgmentCallback
AcknowledgmentCallback
の isAutoAck
public void acknowledge(AcknowledgmentCallback.Status status)
AcknowledgmentCallback
AcknowledgmentCallback
の acknowledge
status
- ステータス。public StringSE toString()
ObjectSE
の toStringSE