Skip to content

Commit d1a5437

Browse files
committed
Fix Sonar Issues
1 parent 97ac358 commit d1a5437

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/listener/CommonContainerStoppingErrorHandler.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ private void stopContainer(MessageListenerContainer container, Exception thrownE
8787
this.executor.execute(() -> container.stop());
8888
// isRunning is false before the container.stop() waits for listener thread
8989
try {
90-
ListenerUtils.stoppableSleep(container, 10_000);
90+
ListenerUtils.stoppableSleep(container, 10_000); // NOSONAR
9191
}
9292
catch (InterruptedException e) {
9393
Thread.currentThread().interrupt();

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public void setAckAfterHandle(boolean ackAfterHandle) {
109109
public void handle(Exception thrownException, @Nullable ConsumerRecords<?, ?> data, Consumer<?, ?> consumer,
110110
MessageListenerContainer container) {
111111

112-
doHandle(thrownException, data, consumer, container, () -> { });
112+
doHandle(thrownException, data, consumer, container, () -> { }); // NOSONAR
113113
}
114114

115115
}

0 commit comments

Comments
 (0)