PassThrough*

This commit is contained in:
dsyer
2009-02-18 08:29:10 +00:00
parent 57cf2b1c0b
commit ae275e8f5d
3 changed files with 8 additions and 8 deletions

View File

@@ -10,7 +10,7 @@ import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.support.PassthroughItemProcessor;
import org.springframework.batch.item.support.PassThroughItemProcessor;
public class FaultTolerantChunkProcessorTests {
@@ -21,7 +21,7 @@ public class FaultTolerantChunkProcessorTests {
@Test
public void testWrite() throws Exception {
FaultTolerantChunkProcessor<String, String> processor = new FaultTolerantChunkProcessor<String, String>(
new PassthroughItemProcessor<String>(), new ItemWriter<String>() {
new PassThroughItemProcessor<String>(), new ItemWriter<String>() {
public void write(List<? extends String> items) throws Exception {
list.addAll(items);
}

View File

@@ -13,7 +13,7 @@ import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.support.PassthroughItemProcessor;
import org.springframework.batch.item.support.PassThroughItemProcessor;
public class SimpleChunkProcessorTests {
@@ -26,7 +26,7 @@ public class SimpleChunkProcessorTests {
@Before
public void setUp() {
processor = new SimpleChunkProcessor<String,String>(new PassthroughItemProcessor<String>(), new ItemWriter<String>() {
processor = new SimpleChunkProcessor<String,String>(new PassThroughItemProcessor<String>(), new ItemWriter<String>() {
public void write(List<? extends String> items) throws Exception {
list.addAll(items);
}

View File

@@ -20,7 +20,7 @@ import org.springframework.batch.core.step.item.SimpleChunkProcessor;
import org.springframework.batch.core.step.item.SimpleChunkProvider;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.support.PassthroughItemProcessor;
import org.springframework.batch.item.support.PassThroughItemProcessor;
import org.springframework.batch.repeat.RepeatOperations;
import org.springframework.batch.repeat.policy.SimpleCompletionPolicy;
import org.springframework.batch.repeat.support.RepeatTemplate;
@@ -45,7 +45,7 @@ public class TestingChunkOrientedTasklet<T> extends ChunkOrientedTasklet<T> {
}
/**
* Creates a {@link PassthroughItemProcessor} and uses it to create an
* Creates a {@link PassThroughItemProcessor} and uses it to create an
* instance of {@link Tasklet}.
*/
public TestingChunkOrientedTasklet(ItemReader<T> itemReader, ItemWriter<T> itemWriter) {
@@ -53,13 +53,13 @@ public class TestingChunkOrientedTasklet<T> extends ChunkOrientedTasklet<T> {
}
/**
* Creates a {@link PassthroughItemProcessor} and uses it to create an
* Creates a {@link PassThroughItemProcessor} and uses it to create an
* instance of {@link Tasklet}.
*/
public TestingChunkOrientedTasklet(ItemReader<T> itemReader, ItemWriter<T> itemWriter,
RepeatOperations repeatOperations) {
super(new SimpleChunkProvider<T>(itemReader, repeatOperations), new SimpleChunkProcessor<T, T>(
new PassthroughItemProcessor<T>(), itemWriter));
new PassThroughItemProcessor<T>(), itemWriter));
}
}