Uses of Class
org.springframework.kafka.retrytopic.DestinationTopicProcessor.Context
-
Uses of DestinationTopicProcessor.Context in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionvoid
DefaultDestinationTopicProcessor.processDestinationTopicProperties
(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) void
DestinationTopicProcessor.processDestinationTopicProperties
(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) Process the destination properties.void
DefaultDestinationTopicProcessor.processRegisteredDestinations
(Consumer<Collection<String>> topicsCallback, DestinationTopicProcessor.Context context) void
DestinationTopicProcessor.processRegisteredDestinations
(Consumer<Collection<String>> topicsConsumer, DestinationTopicProcessor.Context context) Process the registered destinations.void
DefaultDestinationTopicProcessor.registerDestinationTopic
(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) void
DestinationTopicProcessor.registerDestinationTopic
(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) Register the destination topic.