Interface DestinationTopicProcessor

All Known Implementing Classes:
DefaultDestinationTopicProcessor

public interface DestinationTopicProcessor
The DestinationTopicProcessor creates and registers the DestinationTopic instances in the provided DestinationTopicProcessor.Context, also providing callback interfaces to be called upon the context properties.
Since:
2.7
Author:
Tomaz Fernandes, Gary Russell
  • Method Details

    • processDestinationTopicProperties

      void processDestinationTopicProperties(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context)
      Process the destination properties.
      Parameters:
      destinationPropertiesProcessor - the processor.
      context - the context.
    • processRegisteredDestinations

      void processRegisteredDestinations(Consumer<Collection<String>> topicsConsumer, DestinationTopicProcessor.Context context)
      Process the registered destinations.
      Parameters:
      topicsConsumer - the consumer.
      context - the context.
    • registerDestinationTopic

      void registerDestinationTopic(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context)
      Register the destination topic.
      Parameters:
      mainTopicName - the main topic name.
      destinationTopicName - the destination topic name.
      destinationTopicProperties - the destination topic properties.
      context - the context.