Skip to content

Commit f7cbbfe

Browse files
committed
Sonar Fixes
1 parent 35657c6 commit f7cbbfe

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/BackOffHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ default void onNextBackOff(@Nullable MessageListenerContainer container, Excepti
4646
* @param partition the partition.
4747
* @param nextBackOff the next back off.
4848
*/
49-
default void onNextBackOff(@Nullable MessageListenerContainer container, TopicPartition partition,
49+
default void onNextBackOff(MessageListenerContainer container, TopicPartition partition,
5050
long nextBackOff) {
5151

5252
throw new UnsupportedOperationException();

spring-kafka/src/main/java/org/springframework/kafka/listener/ListenerContainerPauseService.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,8 +137,11 @@ public void resume(@NonNull MessageListenerContainer messageListenerContainer) {
137137
}
138138
}
139139

140+
/*
141+
* Callers must ensure this.registry is not null before calling.
142+
*/
140143
private Optional<MessageListenerContainer> getListenerContainer(String listenerId) {
141-
MessageListenerContainer messageListenerContainer = this.registry.getListenerContainer(listenerId);
144+
MessageListenerContainer messageListenerContainer = this.registry.getListenerContainer(listenerId); // NOSONAR
142145
if (messageListenerContainer == null) {
143146
LOGGER.warn(() -> "MessageListenerContainer " + listenerId + " does not exists");
144147
}

0 commit comments

Comments
 (0)