Skip to content

Commit 1026edd

Browse files
committed
Sonar Fixes
1 parent 2f50088 commit 1026edd

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Diff for: spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -549,7 +549,7 @@ private RetryTopicConfigurer createDefaultConfigurer() {
549549
schedW = gac.getBean(RetryTopicSchedulerWrapper.class);
550550
}
551551
KafkaConsumerBackoffManager bom =
552-
rtcs.kafkaConsumerBackoffManager(this.applicationContext, this.registrar.getEndpointRegistry(),
552+
rtcs.kafkaConsumerBackoffManager(this.applicationContext, this.registrar.getEndpointRegistry(), // NOSONAR
553553
schedW, sched);
554554
RetryTopicConfigurer rtc = rtcs.retryTopicConfigurer(bom, destResolver, this.beanFactory);
555555

Diff for: spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerPausingBackOffHandler.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public ContainerPausingBackOffHandler(ListenerContainerPauseService pauser) {
4646
@Override
4747
public void onNextBackOff(@Nullable MessageListenerContainer container, Exception exception, long nextBackOff) {
4848
if (container == null) {
49-
this.defaultBackOffHandler.onNextBackOff(container, exception, nextBackOff);
49+
this.defaultBackOffHandler.onNextBackOff(container, exception, nextBackOff); // NOSONAR
5050
}
5151
else {
5252
this.pauser.pause(container, Duration.ofMillis(nextBackOff));

0 commit comments

Comments
 (0)