Skip to content

Commit

Permalink
GH-3514: RetryableTopic javadoc/test update for defaultRetryTopicKa…
Browse files Browse the repository at this point in the history
…fkaTemplate

Fixes: #3514

#3514

* Fix: Replace `retryTopicDefaultKafkaTemplate` with `defaultRetryTopicKafkaTemplate` in javadocs
* Fix: Replace `retryTopicDefaultKafkaTemplate` with `RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME` in Test Code

(cherry picked from commit f1cb003)
  • Loading branch information
JeonDaehong authored and spring-builds committed Oct 8, 2024
1 parent ff125d2 commit 8ecb85e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@
*
* The bean name of the {@link org.springframework.kafka.core.KafkaTemplate} bean that
* will be used to forward the message to the retry and Dlt topics. If not specified,
* a bean with name {@code retryTopicDefaultKafkaTemplate} or {@code kafkaTemplate}
* a bean with name {@code defaultRetryTopicKafkaTemplate} or {@code kafkaTemplate}
* will be looked up.
*
* @return the kafkaTemplate bean name.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ private Method getAnnotatedMethod(String methodName) {
void shouldProvideFromAnnotation() {

// setup
willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);

// given
RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);
Expand Down Expand Up @@ -149,7 +149,7 @@ void shouldFindNone() {
void shouldProvideFromMetaAnnotation() {

// setup
willReturn(kafkaOperations).given(beanFactory).getBean("retryTopicDefaultKafkaTemplate", KafkaOperations.class);
willReturn(kafkaOperations).given(beanFactory).getBean(RetryTopicBeanNames.DEFAULT_KAFKA_TEMPLATE_BEAN_NAME, KafkaOperations.class);

// given
RetryTopicConfigurationProvider provider = new RetryTopicConfigurationProvider(beanFactory);
Expand Down

0 comments on commit 8ecb85e

Please sign in to comment.