Package org.springframework.kafka.retrytopic.destinationtopic

Class DestinationTopicContainer

java.lang.Object

org.springframework.kafka.retrytopic.destinationtopic.DestinationTopicContainer

All Implemented Interfaces:

java.util.EventListener, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>, DestinationTopicResolver

public class DestinationTopicContainer
extends java.lang.Object
implements DestinationTopicResolver, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

Contains the destination topics and correlates them with their source via the Map<String, DestinationTopicResolver.DestinationsHolder> map. Implements the DestinationTopicResolver interface.

Since:

2.7

Author:

Tomaz Fernandes

Nested Class Summary

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

DestinationTopicResolver.DestinationsHolder

Constructor Summary

Constructors

Constructor	Description
DestinationTopicContainer(java.time.Clock clock)

Method Summary

Modifier and Type	Method	Description
void	addDestinations(java.util.Map<java.lang.String,DestinationTopicResolver.DestinationsHolder> sourceDestinationMapToAdd)
DestinationTopic	getCurrentTopic(java.lang.String topic)
void	onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

DestinationTopicContainer

public DestinationTopicContainer(java.time.Clock clock)

Method Detail

resolveNextDestination

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

Specified by:

resolveNextDestination in interface DestinationTopicResolver

resolveDestinationNextExecutionTimestamp

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

Specified by:

resolveDestinationNextExecutionTimestamp in interface DestinationTopicResolver

getCurrentTopic

public DestinationTopic getCurrentTopic(java.lang.String topic)

Specified by:

getCurrentTopic in interface DestinationTopicResolver

addDestinations

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

Specified by:

addDestinations in interface DestinationTopicResolver

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>