Skip to content

Commit 009abbb

Browse files
committed
Fix Sonar Issues
1 parent 675a68c commit 009abbb

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/ExceptionClassifier.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ private void add(boolean classified, Class<? extends Exception>... exceptionType
165165
*/
166166
@Deprecated
167167
public boolean removeNotRetryableException(Class<? extends Exception> exceptionType) {
168-
return this.removeClassification(exceptionType);
168+
return Boolean.TRUE.equals(removeClassification(exceptionType)) ? true : false;
169169
}
170170

171171
/**

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ public final void setBlockingRetryableExceptions(Class<? extends Exception>... e
196196
() -> "Blocking retryable exceptions have already been set."
197197
+ "Current ones: " + Arrays.toString(this.blockingExceptionTypes)
198198
+ " You provided: " + Arrays.toString(exceptionTypes));
199-
this.blockingExceptionTypes = exceptionTypes;
199+
this.blockingExceptionTypes = Arrays.copyOf(exceptionTypes, exceptionTypes.length);
200200
}
201201

202202
private ConcurrentKafkaListenerContainerFactory<?, ?> doConfigure(

0 commit comments

Comments
 (0)