パッケージ org.springframework.amqp.rabbit.retry

クラス RejectAndDontRequeueRecoverer

java.lang.ObjectSE
org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
実装されたすべてのインターフェース:
MessageRecoverer
public class RejectAndDontRequeueRecoverer extends ObjectSE implements MessageRecoverer
リスナーコンテナーが再キューイングせずにメッセージを拒否する原因となる MessageRecover。これにより、ブローカーがそのように構成されている場合、失敗したメッセージをデッドレター交換 / キューに送信できます。
導入:
1.1.2
作成者:
Gary Russell

  • フィールドの詳細

    • logger

      protected final Log logger

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

    • RejectAndDontRequeueRecoverer

      public RejectAndDontRequeueRecoverer()
      デフォルトの例外メッセージでインスタンスを構築します。

    • RejectAndDontRequeueRecoverer

      public RejectAndDontRequeueRecoverer(StringSE message)
      提供された例外メッセージでインスタンスを構築します。
      パラメーター:
      message - メッセージ。
      導入:
      2.3.7

    • RejectAndDontRequeueRecoverer

      public RejectAndDontRequeueRecoverer(SupplierSE<StringSE> messageSupplier)
      提供された例外メッセージサプライヤーを使用してインスタンスを構築します。
      パラメーター:
      messageSupplier - メッセージサプライヤー。
      導入:
      2.3.7

  • メソッドの詳細

    • recover

      public void recover(Message message, ThrowableSE cause)
      インターフェースからコピーされた説明: MessageRecoverer
      消費されましたがすべての再試行に失敗したメッセージのコールバック。
      次で指定:
      インターフェース MessageRecoverer の recover 
      パラメーター:
      message - 回復へのメッセージ
      cause - エラーの原因