Skip to content

Commit abe720b

Browse files
committed
More Sonar Fixes
1 parent b275384 commit abe720b

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,9 @@ public synchronized void start() {
319319
this.kafkaStreams.cleanUp();
320320
}
321321
this.kafkaStreams.start();
322-
this.listeners.forEach(listener -> listener.streamsAdded(this.beanName, this.kafkaStreams));
322+
for (Listener listener : this.listeners) {
323+
listener.streamsAdded(this.beanName, this.kafkaStreams);
324+
}
323325
this.running = true;
324326
}
325327
catch (Exception e) {

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/SerializationUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,12 +80,12 @@ public static <P, T> BiFunction<P, Headers, T> propertyToMethodInvokingFunction(
8080
+ payloadType.getSimpleName()
8181
+ ")'", e1);
8282
ise.addSuppressed(e);
83-
throw ise;
83+
throw ise; // NOSONAR, lost stack trace
8484
}
8585
catch (SecurityException e1) {
8686
IllegalStateException ise = new IllegalStateException(e1);
8787
ise.addSuppressed(e);
88-
throw ise;
88+
throw ise; // NOSONAR, lost stack trace
8989
}
9090
}
9191
catch (SecurityException e) {

0 commit comments

Comments
 (0)