Skip to content

Commit 3db012f

Browse files
committed
Sonar Fixes
1 parent ce5a8ad commit 3db012f

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

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

+1-1
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();

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

+4-1
Original file line numberDiff line numberDiff line change
@@ -136,8 +136,11 @@ public void resume(MessageListenerContainer messageListenerContainer) {
136136
}
137137
}
138138

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

0 commit comments

Comments
 (0)