パッケージ org.springframework.integration.amqp.inbound

クラス AmqpMessageSource.AmqpAckCallback

java.lang.ObjectSE
org.springframework.integration.amqp.inbound.AmqpMessageSource.AmqpAckCallback
実装されたすべてのインターフェース:
AcknowledgmentCallback, SimpleAcknowledgment
含まれているクラス:
AmqpMessageSource
public static class AmqpMessageSource.AmqpAckCallback extends ObjectSE implements AcknowledgmentCallback

  • コンストラクターの詳細

  • メソッドの詳細

    • getAckInfo

      protected AmqpMessageSource.AmqpAckInfo getAckInfo()

    • setAcknowledged

      protected void setAcknowledged(boolean acknowledged)

    • isAcknowledged

      public boolean isAcknowledged()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      フレームワークが必要に応じて自動確認できるように、実装はこれを実装してユーザーが確認を処理したことを示す必要があります。
      次で指定:
      インターフェース AcknowledgmentCallback の isAcknowledged 
      戻り値:
      メッセージがすでに確認されている場合は true。

    • noAutoAck

      public void noAutoAck()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      SourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。すべての実装がこれをサポートしているわけではありません - たとえば、Kafka メッセージソース。
      次で指定:
      インターフェース AcknowledgmentCallback の noAutoAck 

    • isAutoAck

      public boolean isAutoAck()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      アプリケーションによってまだ確認されていない場合に、この確認が自動確認をサポートする場合は true を返します。
      次で指定:
      インターフェース AcknowledgmentCallback の isAutoAck 
      戻り値:
      自動確認がサポートされている場合は true。

    • acknowledge

      public void acknowledge(AcknowledgmentCallback.Status status)
      インターフェースからコピーされた説明: AcknowledgmentCallback
      メッセージを確認します。
      次で指定:
      インターフェース AcknowledgmentCallback の acknowledge 
      パラメーター:
      status - ステータス。

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString