Package org.springframework.kafka.retrytopic

Class DefaultDestinationTopicProcessor

java.lang.Object

org.springframework.kafka.retrytopic.DefaultDestinationTopicProcessor

All Implemented Interfaces:

DestinationTopicProcessor

public class DefaultDestinationTopicProcessor
extends Object
implements DestinationTopicProcessor

Default implementation of the DestinationTopicProcessor interface.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.kafka.retrytopic.DestinationTopicProcessor

DestinationTopicProcessor.Context

Constructor Summary

Constructors

Constructor	Description
DefaultDestinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)

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>> topicsCallback, DestinationTopicProcessor.Context context)	Process the registered destinations.
void	registerDestinationTopic(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context)	Register the destination topic.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultDestinationTopicProcessor

public DefaultDestinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)

Method Details

processDestinationTopicProperties

public void processDestinationTopicProperties(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor,
 DestinationTopicProcessor.Context context)

Description copied from interface: DestinationTopicProcessor

Process the destination properties.

Specified by:

processDestinationTopicProperties in interface DestinationTopicProcessor

Parameters:

destinationPropertiesProcessor - the processor.

context - the context.

registerDestinationTopic

public void registerDestinationTopic(String mainTopicName,
 String destinationTopicName,
 DestinationTopic.Properties destinationTopicProperties,
 DestinationTopicProcessor.Context context)

Description copied from interface: DestinationTopicProcessor

Register the destination topic.

Specified by:

registerDestinationTopic in interface DestinationTopicProcessor

Parameters:

mainTopicName - the main topic name.

destinationTopicName - the destination topic name.

destinationTopicProperties - the destination topic properties.

context - the context.

processRegisteredDestinations

public void processRegisteredDestinations(Consumer<Collection<String>> topicsCallback,
 DestinationTopicProcessor.Context context)

Description copied from interface: DestinationTopicProcessor

Process the registered destinations.

Specified by:

processRegisteredDestinations in interface DestinationTopicProcessor

Parameters:

topicsCallback - the consumer.

context - the context.