クラス DefaultDestinationTopicProcessor
java.lang.ObjectSE
org.springframework.kafka.retrytopic.DefaultDestinationTopicProcessor
- 実装されているすべてのインターフェース:
DestinationTopicProcessor
DestinationTopicProcessor インターフェースのデフォルト実装。- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes, Gary Russell
ネストされたクラスの要約
インターフェース org.springframework.kafka.retrytopic.DestinationTopicProcessor から継承されたネストクラス / インターフェース
DestinationTopicProcessor.Contextコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明voidprocessDestinationTopicProperties(ConsumerSE<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) 宛先プロパティを処理します。voidprocessRegisteredDestinations(ConsumerSE<CollectionSE<StringSE>> topicsCallback, DestinationTopicProcessor.Context context) 登録された宛先を処理します。voidregisterDestinationTopic(StringSE mainTopicName, @Nullable StringSE destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) 宛先トピックを登録します。
コンストラクターの詳細
DefaultDestinationTopicProcessor
メソッドの詳細
processDestinationTopicProperties
public void processDestinationTopicProperties(ConsumerSE<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) インターフェースからコピーされた説明:DestinationTopicProcessor宛先プロパティを処理します。- 次で指定:
- インターフェース
DestinationTopicProcessorのprocessDestinationTopicProperties - パラメーター:
destinationPropertiesProcessor- プロセッサー。context- コンテキスト。
registerDestinationTopic
public void registerDestinationTopic(StringSE mainTopicName, @Nullable StringSE destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) インターフェースからコピーされた説明:DestinationTopicProcessor宛先トピックを登録します。- 次で指定:
- インターフェース
DestinationTopicProcessorのregisterDestinationTopic - パラメーター:
mainTopicName- メイントピック名。destinationTopicName- 宛先トピック名。destinationTopicProperties- 宛先トピックのプロパティ。context- コンテキスト。
processRegisteredDestinations
public void processRegisteredDestinations(ConsumerSE<CollectionSE<StringSE>> topicsCallback, DestinationTopicProcessor.Context context) インターフェースからコピーされた説明:DestinationTopicProcessor登録された宛先を処理します。- 次で指定:
- インターフェース
DestinationTopicProcessorのprocessRegisteredDestinations - パラメーター:
topicsCallback- コンシューマー。context- コンテキスト。