Package org.springframework.kafka.retrytopic.destinationtopic

Interface DestinationTopicResolver

All Known Implementing Classes:

DestinationTopicContainer

public interface DestinationTopicResolver

Contains methods for resolving the destination to which a message that failed to be processed should be forwarded to, based on the current topic, the attempt and the thrown exception.

Since:

2.7

Author:

Tomaz Fernandes

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	DestinationTopicResolver.DestinationsHolder

Method Summary

Modifier and Type	Method	Description
void	addDestinations(java.util.Map<java.lang.String,DestinationTopicResolver.DestinationsHolder> sourceDestinationMapToAdd)
DestinationTopic	getCurrentTopic(java.lang.String topic)
static DestinationTopicResolver.DestinationsHolder	holderFor(DestinationTopic sourceDestination, DestinationTopic nextDestination)
long	resolveDestinationNextExecutionTimestamp(java.lang.String topic, java.lang.Integer attempt, java.lang.Exception e, long originalTimestamp)
DestinationTopic	resolveNextDestination(java.lang.String topic, java.lang.Integer attempt, java.lang.Exception e, long originalTimestamp)

Method Detail

resolveNextDestination

DestinationTopic resolveNextDestination(java.lang.String topic,
                                        java.lang.Integer attempt,
                                        java.lang.Exception e,
                                        long originalTimestamp)

resolveDestinationNextExecutionTimestamp

long resolveDestinationNextExecutionTimestamp(java.lang.String topic,
                                              java.lang.Integer attempt,
                                              java.lang.Exception e,
                                              long originalTimestamp)

getCurrentTopic

DestinationTopic getCurrentTopic(java.lang.String topic)

addDestinations

void addDestinations(java.util.Map<java.lang.String,DestinationTopicResolver.DestinationsHolder> sourceDestinationMapToAdd)

holderFor

static DestinationTopicResolver.DestinationsHolder holderFor(DestinationTopic sourceDestination,
                                                             DestinationTopic nextDestination)