パッケージ org.springframework.kafka.retrytopic

インターフェース DestinationTopicResolver

すべてのスーパーインターフェース:
DestinationTopicContainer
すべての既知の実装クラス:
DefaultDestinationTopicResolver
public interface DestinationTopicResolver extends DestinationTopicContainer
処理に失敗したメッセージの転送先となる宛先を解決するためのメソッドを提供します。
導入:
2.7
作成者:
Tomaz Fernandes, Gary Russell

  • メソッドの詳細

    • resolveDestinationTopic

      DestinationTopic resolveDestinationTopic(StringSE mainListenerId, StringSE topic, IntegerSE attempt, ExceptionSE e, long originalTimestamp)
      失敗したメッセージの宛先トピックを解決します。
      パラメーター:
      mainListenerId - リスナー ID。
      topic - メッセージの現在のトピック。
      attempt - そのメッセージに対してすでに行われた処理の試行回数。
      e - メッセージ処理がスローした例外
      originalTimestamp - メッセージを最初に処理しようとしたときに例外がスローされた時刻。
      戻り値:
      指定されたパラメーターの DestinationTopic。