OPEN - issue BATCH-771: Refactor Listeners for chunk changes
Make sure commit count is updated
This commit is contained in:
@@ -37,14 +37,4 @@ public class StepContributionTests extends TestCase {
|
||||
assertEquals(1, contribution.getItemCount());
|
||||
}
|
||||
|
||||
/**
|
||||
* Test method for
|
||||
* {@link org.springframework.batch.core.StepContribution#incrementCommitCount()}.
|
||||
*/
|
||||
public void testIncrementCommitCount() {
|
||||
assertEquals(0, contribution.getCommitCount());
|
||||
contribution.incrementCommitCount();
|
||||
assertEquals(1, contribution.getCommitCount());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -125,9 +125,13 @@ public class StepExecutionTests extends TestCase {
|
||||
|
||||
public void testApplyContribution() throws Exception {
|
||||
StepContribution contribution = execution.createStepContribution();
|
||||
contribution.incrementCommitCount();
|
||||
contribution.incrementReadSkipCount();
|
||||
contribution.incrementWriteSkipCount();
|
||||
contribution.incrementItemCount();
|
||||
execution.apply(contribution);
|
||||
assertEquals(1, execution.getCommitCount());
|
||||
assertEquals(1, execution.getReadSkipCount());
|
||||
assertEquals(1, execution.getWriteSkipCount());
|
||||
assertEquals(1, execution.getItemCount());
|
||||
}
|
||||
|
||||
public void testTerminateOnly() throws Exception {
|
||||
|
||||
@@ -127,6 +127,7 @@ public class StepHandlerStepTests extends TestCase {
|
||||
step.execute(stepExecution);
|
||||
assertEquals(1, processed.size());
|
||||
assertEquals(1, stepExecution.getItemCount());
|
||||
assertEquals(1, stepExecution.getCommitCount());
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user