インターフェース DestinationTopicResolver
- すべてのスーパーインターフェース:
DestinationTopicContainer
- すべての既知の実装クラス:
DefaultDestinationTopicResolver
処理に失敗したメッセージの転送先となる宛先を解決するためのメソッドを提供します。
- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes, Gary Russell
メソッドのサマリー
修飾子と型メソッド説明resolveDestinationTopic(StringSE mainListenerId, StringSE topic, IntegerSE attempt, ExceptionSE e, long originalTimestamp) 失敗したメッセージの宛先トピックを解決します。インターフェース org.springframework.kafka.retrytopic.DestinationTopicContainer から継承されたメソッド
addDestinationTopics, getDestinationTopicByName, getDltFor, getNextDestinationTopicFor
メソッドの詳細
resolveDestinationTopic
DestinationTopic resolveDestinationTopic(StringSE mainListenerId, StringSE topic, IntegerSE attempt, ExceptionSE e, long originalTimestamp) 失敗したメッセージの宛先トピックを解決します。- パラメーター:
mainListenerId- リスナー ID。topic- メッセージの現在のトピック。attempt- そのメッセージに対してすでに行われた処理の試行回数。e- メッセージ処理がスローした例外originalTimestamp- メッセージを最初に処理しようとしたときに例外がスローされた時刻。- 戻り値:
- 指定されたパラメーターの
DestinationTopic。