Package org.springframework.kafka.retrytopic

Class DefaultDestinationTopicResolver

java.lang.Object

org.springframework.kafka.listener.KafkaExceptionLogLevelAware

org.springframework.kafka.listener.ExceptionClassifier

org.springframework.kafka.retrytopic.DefaultDestinationTopicResolver

All Implemented Interfaces:

EventListener, ApplicationListener<ContextRefreshedEvent>, DestinationTopicContainer, DestinationTopicResolver

public class DefaultDestinationTopicResolver
extends ExceptionClassifier
implements DestinationTopicResolver, ApplicationListener<ContextRefreshedEvent>

Default implementation of the DestinationTopicResolver interface. The container is closed when a ContextRefreshedEvent is received and no more destinations can be added after that.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell, Yvette Quinby

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultDestinationTopicResolver.DestinationTopicHolder

Constructor Summary

Constructors

Constructor	Description
DefaultDestinationTopicResolver(Clock clock, ApplicationContext applicationContext)

Method Summary

Modifier and Type	Method	Description
void	addDestinationTopics(List<DestinationTopic> destinationsToAdd)	Adds the provided destination topics to the container.
DestinationTopic	getDestinationTopicByName(String topic)	Returns the DestinationTopic instance registered for that topic.
boolean	isContextRefreshed()	Return true if the application context is refreshed.
void	onApplicationEvent(ContextRefreshedEvent event)
DestinationTopic	resolveDestinationTopic(String topic, Integer attempt, Exception e, long originalTimestamp)	Resolves the destination topic for the failed message.

Methods inherited from class org.springframework.kafka.listener.ExceptionClassifier

addNotRetryableExceptions, addRetryableExceptions, defaultFalse, getClassifier, removeClassification, removeNotRetryableException, setClassifications

Methods inherited from class org.springframework.kafka.listener.KafkaExceptionLogLevelAware

getLogLevel, setLogLevel

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDestinationTopicResolver

public DefaultDestinationTopicResolver(Clock clock,
 ApplicationContext applicationContext)

Method Details

resolveDestinationTopic

public DestinationTopic resolveDestinationTopic(String topic,
 Integer attempt,
 Exception e,
 long originalTimestamp)

Description copied from interface: DestinationTopicResolver

Resolves the destination topic for the failed message.

Specified by:

resolveDestinationTopic in interface DestinationTopicResolver

Parameters:

topic - the current topic for the message.

attempt - the number of processing attempts already made for that message.

e - the exception the message processing has thrown

originalTimestamp - the time when the first attempt to process the message threw an exception.

Returns:

the DestinationTopic for the given parameters.

getDestinationTopicByName

public DestinationTopic getDestinationTopicByName(String topic)

Description copied from interface: DestinationTopicContainer

Returns the DestinationTopic instance registered for that topic.

Specified by:

getDestinationTopicByName in interface DestinationTopicContainer

Parameters:

topic - the topic name of the DestinationTopic to be returned.

Returns:

the DestinationTopic instance registered for that topic.

addDestinationTopics

public void addDestinationTopics(List<DestinationTopic> destinationsToAdd)

Description copied from interface: DestinationTopicContainer

Adds the provided destination topics to the container.

Specified by:

addDestinationTopics in interface DestinationTopicContainer

Parameters:

destinationsToAdd - the DestinationTopic list to add.

onApplicationEvent

public void onApplicationEvent(ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface ApplicationListener<ContextRefreshedEvent>

isContextRefreshed

public boolean isContextRefreshed()

Return true if the application context is refreshed.

Returns:

true if refreshed.

Since:

2.7.8