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

OPEN - issue BATCH-1198: processSkipCount and filterCount mixed up

Browse Source
This commit is contained in:
dsyer
2009-04-07 11:46:31 +00:00
parent f12edbb546
commit f708120524
2 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
spring-batch-core/src/test/java/org/springframework/batch/core/step/item/FaultTolerantChunkProcessorTests.java
View File

@@ -66,6 +66,31 @@ public class FaultTolerantChunkProcessorTests {
Chunk<String> inputs = new Chunk<String>(Arrays.asList("1", "2"));
processor.process(contribution, inputs);
assertEquals(1, list.size());
assertEquals(1, contribution.getFilterCount());
}
@Test
public void testFilterCountOnSkip() throws Exception {
processor.setProcessSkipPolicy(new AlwaysSkipItemSkipPolicy());
processor.setItemProcessor(new ItemProcessor<String, String>() {
public String process(String item) throws Exception {
if (item.equals("1")) {
throw new RuntimeException("Skippable");
}
return item;
}
});
Chunk<String> inputs = new Chunk<String>(Arrays.asList("1", "2"));
try {
processor.process(contribution, inputs);
fail("Expected Exception");
} catch (Exception e) {
assertEquals("Skippable", e.getMessage());
}
processor.process(contribution, inputs);
assertEquals(1, list.size());
assertEquals(1, contribution.getSkipCount());
assertEquals(0, contribution.getFilterCount());
}
@Test