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