|
20 | 20 | * |
21 | 21 | * Contains the internal bean names that will be used by the retryable topic configuration. |
22 | 22 | * |
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 |
24 | 24 | * of the default one. |
25 | 25 | * |
26 | 26 | * @author Tomaz Fernandes |
|
29 | 29 | */ |
30 | 30 | public abstract class RetryTopicInternalBeanNames { |
31 | 31 |
|
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"; |
33 | 36 |
|
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"; |
35 | 41 |
|
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"; |
37 | 46 |
|
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"; |
39 | 51 |
|
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"; |
41 | 56 |
|
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"; |
43 | 61 |
|
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"; |
45 | 67 |
|
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"; |
47 | 72 |
|
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"; |
49 | 78 |
|
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"; |
51 | 83 |
|
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"; |
53 | 88 |
|
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"; |
55 | 93 |
|
56 | 94 | /** |
57 | | - * Internal Back Off Clock Bean Name. |
| 95 | + * The {@link java.time.Clock} bean name that will be used for backing off partitions. |
58 | 96 | */ |
59 | 97 | public static final String INTERNAL_BACKOFF_CLOCK_BEAN_NAME = "internalBackOffClock"; |
60 | 98 |
|
61 | 99 | /** |
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. |
63 | 101 | */ |
64 | 102 | public static final String DEFAULT_KAFKA_TEMPLATE_BEAN_NAME = "retryTopicDefaultKafkaTemplate"; |
65 | 103 |
|
66 | 104 | /** |
67 | | - * RetryTopicBootstrapper bean name. |
| 105 | + * {@link RetryTopicBootstrapper} bean name. |
68 | 106 | */ |
69 | 107 | public static final String RETRY_TOPIC_BOOTSTRAPPER = "internalRetryTopicBootstrapper"; |
70 | 108 |
|
71 | 109 | /** |
72 | | - * RetryTopicConfigurer bean name. |
| 110 | + * {@link RetryTopicConfigurer} bean name. |
73 | 111 | */ |
74 | 112 | public static final String RETRY_TOPIC_CONFIGURER = "internalRetryTopicConfigurer"; |
75 | 113 |
|
|
0 commit comments