Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Sonar issues

Browse Source
This commit is contained in:
Gary Russell
2019-10-05 09:15:57 -04:00
parent 457e63a533
commit b53c9348b3
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka/src/main/java/org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java
View File

@@ -167,8 +167,8 @@ public class DefaultAfterRollbackProcessor<K, V> extends FailedRecordProcessor i
* @see #setKafkaTemplate(KafkaTemplate)
*/
@Override
public void setCommitRecovered(boolean commitRecovered) {
super.setCommitRecovered(commitRecovered); // NOSONAR enhanced javadoc
public void setCommitRecovered(boolean commitRecovered) { // NOSONAR enhanced javadoc
super.setCommitRecovered(commitRecovered);
}
/**

3
spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordProcessor.java
View File

@@ -195,8 +195,7 @@ public abstract class FailedRecordProcessor {
classified.put(MethodArgumentResolutionException.class, false);
classified.put(NoSuchMethodException.class, false);
classified.put(ClassCastException.class, false);
ExtendedBinaryExceptionClassifier defaultClassifier = new ExtendedBinaryExceptionClassifier(classified, true);
return defaultClassifier;
return new ExtendedBinaryExceptionClassifier(classified, true);
}
/**