Package org.springframework.kafka.retrytopic

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	DestinationTopicProcessor.Context

Method Summary

Modifier and Type	Method	Description
void	processDestinationTopicProperties(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context)	Process the destination properties.
void	processRegisteredDestinations(Consumer<Collection<String>> topicsConsumer, DestinationTopicProcessor.Context context)	Process the registered destinations.
void	registerDestinationTopic(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context)	Register the destination topic.

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.