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

インターフェース DestinationTopicProcessor

すべての既知の実装クラス:
DefaultDestinationTopicProcessor
public interface DestinationTopicProcessor
DestinationTopicProcessor は、提供された DestinationTopicProcessor.Context に DestinationTopic インスタンスを作成して登録し、コンテキストプロパティで呼び出されるコールバックインターフェースも提供します。
導入:
2.7
作成者:
Tomaz Fernandes, Gary Russell

  • メソッドの詳細

    • processDestinationTopicProperties

      void processDestinationTopicProperties(ConsumerSE<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context)
      宛先プロパティを処理します。
      パラメーター:
      destinationPropertiesProcessor - プロセッサー。
      context - コンテキスト。

    • processRegisteredDestinations

      void processRegisteredDestinations(ConsumerSE<CollectionSE<StringSE>> topicsConsumer, DestinationTopicProcessor.Context context)
      登録された宛先を処理します。
      パラメーター:
      topicsConsumer - コンシューマー。
      context - コンテキスト。

    • registerDestinationTopic

      void registerDestinationTopic(StringSE mainTopicName, StringSE destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context)
      宛先トピックを登録します。
      パラメーター:
      mainTopicName - メイントピック名。
      destinationTopicName - 宛先トピック名。
      destinationTopicProperties - 宛先トピックのプロパティ。
      context - コンテキスト。