Incomplete - task 84: Fix samples
Switch default skip policy to Never
This commit is contained in:
@@ -22,8 +22,8 @@ import org.springframework.batch.core.domain.Step;
|
||||
import org.springframework.batch.core.domain.StepExecution;
|
||||
import org.springframework.batch.core.domain.StepSupport;
|
||||
import org.springframework.batch.core.repository.JobRepository;
|
||||
import org.springframework.batch.execution.step.support.AlwaysSkipItemSkipPolicy;
|
||||
import org.springframework.batch.execution.step.support.DefaultItemFailureHandler;
|
||||
import org.springframework.batch.execution.step.support.NeverSkipItemSkipPolicy;
|
||||
import org.springframework.batch.io.exception.BatchCriticalException;
|
||||
import org.springframework.batch.item.ItemReader;
|
||||
import org.springframework.batch.item.ItemWriter;
|
||||
@@ -58,7 +58,7 @@ public abstract class AbstractStep extends StepSupport implements InitializingBe
|
||||
|
||||
protected ItemWriter itemWriter;
|
||||
|
||||
protected ItemSkipPolicy itemSkipPolicy = new AlwaysSkipItemSkipPolicy();
|
||||
protected ItemSkipPolicy itemSkipPolicy = new NeverSkipItemSkipPolicy();
|
||||
|
||||
protected ItemFailureHandler itemFailureHandler = new DefaultItemFailureHandler();
|
||||
|
||||
|
||||
@@ -176,7 +176,6 @@ public class SimpleJobTests extends TestCase {
|
||||
throw new RuntimeException("Foo");
|
||||
}
|
||||
});
|
||||
step.setItemSkipPolicy(new NeverSkipItemSkipPolicy());
|
||||
step.afterPropertiesSet();
|
||||
job.setSteps(Collections.singletonList(step));
|
||||
|
||||
|
||||
@@ -38,7 +38,6 @@ import org.springframework.batch.execution.repository.dao.MapStepDao;
|
||||
import org.springframework.batch.execution.scope.StepScope;
|
||||
import org.springframework.batch.execution.scope.StepSynchronizationManager;
|
||||
import org.springframework.batch.execution.step.support.JobRepositorySupport;
|
||||
import org.springframework.batch.execution.step.support.NeverSkipItemSkipPolicy;
|
||||
import org.springframework.batch.execution.step.support.StepInterruptionPolicy;
|
||||
import org.springframework.batch.io.exception.BatchCriticalException;
|
||||
import org.springframework.batch.item.ExecutionContext;
|
||||
@@ -540,7 +539,6 @@ public class ItemOrientedStepTests extends TestCase {
|
||||
throw new ResetFailedException("Bar");
|
||||
}
|
||||
});
|
||||
itemOrientedStep.setItemSkipPolicy(new NeverSkipItemSkipPolicy());
|
||||
|
||||
Step step = new StepSupport("stepName");
|
||||
JobExecution jobExecutionContext = jobInstance.createJobExecution();
|
||||
|
||||
Reference in New Issue
Block a user