OPEN - BATCH-803: Add non-buffering ChunkOrientedTasklet (or option in existing one) plus flag for factory bean
moved read counting out of process method and fixed wrong count assertions in tests
This commit is contained in:
@@ -250,7 +250,7 @@ public class StatefulRetryTaskletTests {
|
||||
handler.execute(contribution, attributes);
|
||||
assertEquals(1, chunk.getSkips().size());
|
||||
|
||||
assertEquals(2, contribution.getReadCount());
|
||||
assertEquals(3, contribution.getReadCount());
|
||||
assertEquals(1, contribution.getProcessSkipCount());
|
||||
assertEquals(5, processed.size());
|
||||
assertEquals("[p1, p2]", written.toString());
|
||||
@@ -305,7 +305,7 @@ public class StatefulRetryTaskletTests {
|
||||
// expected
|
||||
}
|
||||
assertTrue(attributes.hasAttribute("INPUT_BUFFER_KEY"));
|
||||
assertEquals(0, contribution.getReadCount());
|
||||
assertEquals(3, contribution.getReadCount());
|
||||
assertEquals(2, contribution.getProcessSkipCount());
|
||||
// Just before the skip at the end we process once more
|
||||
assertEquals(3, processed.size());
|
||||
|
||||
Reference in New Issue
Block a user