クラス DefaultDestinationTopicProcessor
java.lang.ObjectSE
org.springframework.kafka.retrytopic.DefaultDestinationTopicProcessor
- 実装されたすべてのインターフェース:
DestinationTopicProcessor
DestinationTopicProcessor
インターフェースのデフォルト実装。- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes, Gary Russell
ネストされたクラスのサマリー
インターフェース org.springframework.kafka.retrytopic.DestinationTopicProcessor から継承されたネストクラス / インターフェース
DestinationTopicProcessor.Context
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明void
processDestinationTopicProperties
(ConsumerSE<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) 宛先プロパティを処理します。void
processRegisteredDestinations
(ConsumerSE<CollectionSE<StringSE>> topicsCallback, DestinationTopicProcessor.Context context) 登録された宛先を処理します。void
registerDestinationTopic
(StringSE mainTopicName, 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, 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
- コンテキスト。