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

BATCH-2062: Updated from code review

Browse Source
This commit is contained in:
Michael Minella
2013-08-12 09:21:20 -05:00
parent b8479493bd
commit aa73805a24
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/builder/JsrFaultTolerantStepBuilder.java
View File

@@ -63,8 +63,7 @@ public class JsrFaultTolerantStepBuilder<I, O> extends FaultTolerantStepBuilder<
@Override
@SuppressWarnings({"unchecked", "rawtypes"})
protected ChunkProcessor<I> createChunkProcessor() {
SkipPolicy skipPolicy = createSkipPolicy();
skipPolicy = getFatalExceptionAwareProxy(skipPolicy);
SkipPolicy skipPolicy = getFatalExceptionAwareProxy(createSkipPolicy());
JsrFaultTolerantChunkProcessor chunkProcessor = new JsrFaultTolerantChunkProcessor(getReader(), getProcessor(),
getWriter(), createChunkOperations(), createRetryOperations());
chunkProcessor.setSkipPolicy(skipPolicy);

2
spring-batch-core/src/main/java/org/springframework/batch/core/jsr/step/item/JsrChunkProcessor.java
View File

@@ -101,7 +101,7 @@ public class JsrChunkProcessor<I,O> implements ChunkProcessor<I> {
O processedItem = transform(contribution, item);
if(item != null && processedItem == null) {
if(processedItem == null) {
filterCount.incrementAndGet();
} else {
output.add(processedItem);