Skip to content

Commit 4404fa7

Browse files
tomazfernandesgaryrussell
authored andcommitted
GH-1917 - Make RetryTopic bean names public
Add javadocs
1 parent b8ce3f0 commit 4404fa7

File tree

1 file changed

+55
-17
lines changed

1 file changed

+55
-17
lines changed

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/RetryTopicInternalBeanNames.java

Lines changed: 55 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
*
2121
* Contains the internal bean names that will be used by the retryable topic configuration.
2222
*
23-
* If you provide a bean of your own with the same name that instance will be used instead
23+
* If you provide a bean of your own with the same name, your instance will be used instead
2424
* of the default one.
2525
*
2626
* @author Tomaz Fernandes
@@ -29,47 +29,85 @@
2929
*/
3030
public abstract class RetryTopicInternalBeanNames {
3131

32-
static final String DESTINATION_TOPIC_PROCESSOR_NAME = "internalDestinationTopicProcessor";
32+
/**
33+
* {@link DestinationTopicProcessor} bean name.
34+
*/
35+
public static final String DESTINATION_TOPIC_PROCESSOR_NAME = "internalDestinationTopicProcessor";
3336

34-
static final String KAFKA_CONSUMER_BACKOFF_MANAGER = "internalKafkaConsumerBackoffManager";
37+
/**
38+
* {@link org.springframework.kafka.listener.KafkaConsumerBackoffManager} bean name.
39+
*/
40+
public static final String KAFKA_CONSUMER_BACKOFF_MANAGER = "internalKafkaConsumerBackoffManager";
3541

36-
static final String LISTENER_CONTAINER_FACTORY_RESOLVER_NAME = "internalListenerContainerFactoryResolver";
42+
/**
43+
* {@link ListenerContainerFactoryResolver} bean name.
44+
*/
45+
public static final String LISTENER_CONTAINER_FACTORY_RESOLVER_NAME = "internalListenerContainerFactoryResolver";
3746

38-
static final String LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME = "internalListenerContainerFactoryConfigurer";
47+
/**
48+
* {@link ListenerContainerFactoryConfigurer} bean name.
49+
*/
50+
public static final String LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME = "internalListenerContainerFactoryConfigurer";
3951

40-
static final String DEAD_LETTER_PUBLISHING_RECOVERER_PROVIDER_NAME = "internalDeadLetterPublishingRecovererProvider";
52+
/**
53+
* {@link DeadLetterPublishingRecovererFactory} bean name.
54+
*/
55+
public static final String DEAD_LETTER_PUBLISHING_RECOVERER_PROVIDER_NAME = "internalDeadLetterPublishingRecovererProvider";
4156

42-
static final String DESTINATION_TOPIC_CONTAINER_NAME = "internalDestinationTopicContainer";
57+
/**
58+
* {@link DestinationTopicContainer} bean name.
59+
*/
60+
public static final String DESTINATION_TOPIC_CONTAINER_NAME = "internalDestinationTopicContainer";
4361

44-
static final String DEFAULT_LISTENER_FACTORY_BEAN_NAME = "internalRetryTopicListenerContainerFactory";
62+
/**
63+
* The default {@link org.springframework.kafka.config.KafkaListenerContainerFactory}
64+
* bean name that will be looked up if no other is provided.
65+
*/
66+
public static final String DEFAULT_LISTENER_FACTORY_BEAN_NAME = "internalRetryTopicListenerContainerFactory";
4567

46-
static final String BACKOFF_SLEEPER_BEAN_NAME = "internalBackoffSleeper";
68+
/**
69+
* {@link org.springframework.retry.backoff.Sleeper} bean name.
70+
*/
71+
public static final String BACKOFF_SLEEPER_BEAN_NAME = "internalBackoffSleeper";
4772

48-
static final String BACKOFF_TASK_EXECUTOR = "internalBackOffTaskExecutor";
73+
/**
74+
* {@link org.springframework.core.task.TaskExecutor} bean name to be used.
75+
* in the {@link org.springframework.kafka.listener.WakingKafkaConsumerTimingAdjuster}
76+
*/
77+
public static final String BACKOFF_TASK_EXECUTOR = "internalBackOffTaskExecutor";
4978

50-
static final String INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER = "internalKafkaConsumerTimingAdjustmentManager";
79+
/**
80+
* {@link org.springframework.kafka.listener.KafkaConsumerTimingAdjuster} bean name.
81+
*/
82+
public static final String INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER = "internalKafkaConsumerTimingAdjustmentManager";
5183

52-
static final String INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY = "internalKafkaConsumerBackOffManagerFactory";
84+
/**
85+
* {@link org.springframework.kafka.listener.KafkaBackOffManagerFactory} bean name.
86+
*/
87+
public static final String INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY = "internalKafkaConsumerBackOffManagerFactory";
5388

54-
static final String RETRY_TOPIC_NAMES_PROVIDER_FACTORY = "internalRetryTopicNamesProviderFactory";
89+
/**
90+
* {@link RetryTopicNamesProviderFactory} bean name.
91+
*/
92+
public static final String RETRY_TOPIC_NAMES_PROVIDER_FACTORY = "internalRetryTopicNamesProviderFactory";
5593

5694
/**
57-
* Internal Back Off Clock Bean Name.
95+
* The {@link java.time.Clock} bean name that will be used for backing off partitions.
5896
*/
5997
public static final String INTERNAL_BACKOFF_CLOCK_BEAN_NAME = "internalBackOffClock";
6098

6199
/**
62-
* Default Kafka template bean name for publishing to retry topics.
100+
* Default {@link org.springframework.kafka.core.KafkaTemplate} bean name for publishing to retry topics.
63101
*/
64102
public static final String DEFAULT_KAFKA_TEMPLATE_BEAN_NAME = "retryTopicDefaultKafkaTemplate";
65103

66104
/**
67-
* RetryTopicBootstrapper bean name.
105+
* {@link RetryTopicBootstrapper} bean name.
68106
*/
69107
public static final String RETRY_TOPIC_BOOTSTRAPPER = "internalRetryTopicBootstrapper";
70108

71109
/**
72-
* RetryTopicConfigurer bean name.
110+
* {@link RetryTopicConfigurer} bean name.
73111
*/
74112
public static final String RETRY_TOPIC_CONFIGURER = "internalRetryTopicConfigurer";
75113

0 commit comments

Comments
 (0)