Skip to content

Commit 9e123ef

Browse files
committed
Sonar Fixes
1 parent 3db012f commit 9e123ef

File tree

3 files changed

+6
-13
lines changed

3 files changed

+6
-13
lines changed

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

+6-5
Original file line numberDiff line numberDiff line change
@@ -216,13 +216,14 @@ private Throwable shallowTraverseCauseChain(Throwable thrownException) {
216216

217217
@Nullable
218218
private Throwable traverseCauseChain(Throwable thrownException) {
219-
while (thrownException != null && thrownException.getCause() != null) {
220-
if (this.classifier.classify(thrownException)) { // NOSONAR using Boolean here is not dangerous
221-
return thrownException;
219+
Throwable cause = thrownException;
220+
while (cause != null && cause.getCause() != null) {
221+
if (this.classifier.classify(cause)) { // NOSONAR using Boolean here is not dangerous
222+
return cause;
222223
}
223-
thrownException = thrownException.getCause();
224+
cause = cause.getCause();
224225
}
225-
return thrownException;
226+
return cause;
226227
}
227228

228229
}

Diff for: spring-kafka/src/main/java/org/springframework/kafka/retrytopic/ListenerContainerFactoryConfigurer.java

-6
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,6 @@
2222
import java.util.function.Consumer;
2323
import java.util.regex.Pattern;
2424

25-
import org.apache.commons.logging.LogFactory;
26-
27-
import org.springframework.core.log.LogAccessor;
2825
import org.springframework.kafka.KafkaException;
2926
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
3027
import org.springframework.kafka.config.KafkaListenerContainerFactory;
@@ -61,9 +58,6 @@
6158
*/
6259
public class ListenerContainerFactoryConfigurer {
6360

64-
private static final LogAccessor LOGGER = new LogAccessor(
65-
LogFactory.getLog(ListenerContainerFactoryConfigurer.class));
66-
6761
private BackOff providedBlockingBackOff = null;
6862

6963
private Class<? extends Exception>[] blockingExceptionTypes = null;

Diff for: spring-kafka/src/main/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationSupport.java

-2
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,6 @@
6868
*/
6969
public class RetryTopicConfigurationSupport {
7070

71-
private static final String BACK_OFF_MANAGER_THREAD_EXECUTOR_BEAN_NAME = "backOffManagerThreadExecutor";
72-
7371
private static final AtomicBoolean ONLY_ONE_ALLOWED = new AtomicBoolean(true);
7472

7573
private final RetryTopicComponentFactory componentFactory = createComponentFactory();

0 commit comments

Comments
 (0)