Package org.springframework.kafka.retrytopic

Interface DestinationTopicResolver

All Superinterfaces:

DestinationTopicContainer

All Known Implementing Classes:

DefaultDestinationTopicResolver

public interface DestinationTopicResolver
extends DestinationTopicContainer

Provides methods for resolving the destination to which a message that failed to be processed should be forwarded to.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell

Method Summary

Modifier and Type	Method	Description
DestinationTopic	resolveDestinationTopic(String mainListenerId, String topic, Integer attempt, Exception e, long originalTimestamp)	Resolves the destination topic for the failed message.

Methods inherited from interface org.springframework.kafka.retrytopic.DestinationTopicContainer

addDestinationTopics, getDestinationTopicByName, getDltFor, getNextDestinationTopicFor

Method Details

resolveDestinationTopic

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

Resolves the destination topic for the failed message.

Parameters:

mainListenerId - the listener id.

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.