From 3acd3228d312773c68c1be99de12932182df5c91 Mon Sep 17 00:00:00 2001 From: robokaso Date: Thu, 9 Oct 2008 11:16:11 +0000 Subject: [PATCH] RESOLVED - BATCH-779: RFC: make FieldSetMapper and LineAggregator extend ItemProcessor reverted to original method names --- .../batch/item/file/FlatFileItemWriter.java | 2 +- .../mapping/BeanWrapperFieldSetMapper.java | 8 ++-- .../item/file/mapping/DefaultLineMapper.java | 2 +- .../item/file/mapping/FieldSetMapper.java | 8 +++- .../mapping/PassThroughFieldSetMapper.java | 2 +- .../file/transform/AbstractLineTokenizer.java | 2 +- .../transform/DelimitedLineAggregator.java | 2 +- .../transform/FormatterLineAggregator.java | 2 +- .../item/file/transform/LineAggregator.java | 11 +++-- .../item/file/transform/LineTokenizer.java | 11 ++++- .../transform/PassThroughLineAggregator.java | 4 +- .../PrefixMatchingCompositeLineTokenizer.java | 4 +- .../RecursiveCollectionLineAggregator.java | 4 +- .../item/file/FlatFileItemWriterTests.java | 6 +-- .../BeanWrapperFieldSetMapperTests.java | 28 ++++++------ .../file/mapping/DefaultLineMapperTests.java | 4 +- .../PassThroughFieldSetMapperTests.java | 4 +- .../DelimitedLineAggregatorTests.java | 4 +- .../DelimitedLineTokenizerTests.java | 44 +++++++++---------- .../transform/FixedLengthTokenizerTests.java | 32 +++++++------- .../FormatterLineAggregatorTests.java | 18 ++++---- .../PassThroughLineAggregatorTests.java | 4 +- ...ixMatchingCompositeLineTokenizerTests.java | 18 ++++---- ...cursiveCollectionItemTransformerTests.java | 6 +-- .../support/AbstractTradeBatchTests.java | 2 +- .../football/internal/GameFieldSetMapper.java | 2 +- .../internal/PlayerFieldSetMapper.java | 2 +- .../AggregateItemFieldSetMapper.java | 4 +- .../order/internal/AddressFieldSetMapper.java | 2 +- .../order/internal/BillingFieldSetMapper.java | 2 +- .../internal/CustomerFieldSetMapper.java | 2 +- .../order/internal/HeaderFieldSetMapper.java | 2 +- .../internal/OrderItemFieldSetMapper.java | 2 +- .../order/internal/OrderItemReader.java | 16 +++---- .../domain/order/internal/OrderProcessor.java | 12 ++--- .../internal/ShippingFieldSetMapper.java | 2 +- .../CompositeCustomerUpdateLineTokenizer.java | 6 +-- .../trade/CustomerUpdateFieldSetMapper.java | 2 +- .../trade/internal/TradeFieldSetMapper.java | 2 +- .../AggregateItemFieldSetMapperTests.java | 16 +++---- .../domain/order/OrderItemReaderTests.java | 14 +++--- ...ositeCustomerUpdateLineTokenizerTests.java | 10 ++--- .../support/AbstractFieldSetMapperTests.java | 2 +- 43 files changed, 174 insertions(+), 158 deletions(-) diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java index 80e88c5b0..4d5b6b7b7 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java @@ -189,7 +189,7 @@ public class FlatFileItemWriter extends ExecutionContextUserSupport implement StringBuilder lines = new StringBuilder(); int lineCount = 0; for (T item : items) { - lines.append(lineAggregator.process(item) + lineSeparator); + lines.append(lineAggregator.aggregate(item) + lineSeparator); lineCount++; } try { diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapper.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapper.java index 84b7a8ba9..b4e5f8c2d 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapper.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapper.java @@ -102,7 +102,7 @@ public class BeanWrapperFieldSetMapper extends DefaultPropertyEditorRegistrar /** * The bean name (id) for an object that can be populated from the field set - * that will be passed into {@link #process(FieldSet)}. Typically a + * that will be passed into {@link #map(FieldSet)}. Typically a * prototype scoped bean so that a new instance is returned for each field * set mapped. * @@ -118,7 +118,7 @@ public class BeanWrapperFieldSetMapper extends DefaultPropertyEditorRegistrar /** * Public setter for the type of bean to create instead of using a prototype * bean. An object of this type will be created from its default constructor - * for every call to {@link #process(FieldSet)}.
+ * for every call to {@link #map(FieldSet)}.
* * Either this property or the prototype bean name must be specified, but * not both. @@ -153,10 +153,10 @@ public class BeanWrapperFieldSetMapper extends DefaultPropertyEditorRegistrar * the {@link DataBinder} from {@link #createBinder(Object)} has errors * after binding). * - * @see org.springframework.batch.item.file.mapping.FieldSetMapper#process(FieldSet) + * @see org.springframework.batch.item.file.mapping.FieldSetMapper#map(FieldSet) */ @SuppressWarnings("unchecked") - public T process(FieldSet fs) { + public T map(FieldSet fs) { T copy = getBean(); DataBinder binder = createBinder(copy); binder.bind(new MutablePropertyValues(getBeanProperties(copy, fs.getProperties()))); diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/DefaultLineMapper.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/DefaultLineMapper.java index fed622bbe..182fca427 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/DefaultLineMapper.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/DefaultLineMapper.java @@ -17,7 +17,7 @@ public class DefaultLineMapper implements LineMapper { private FieldSetMapper fieldSetMapper; public T mapLine(String line, int lineNumber) throws Exception { - return fieldSetMapper.process(tokenizer.process(line)); + return fieldSetMapper.map(tokenizer.tokenize(line)); } public void setLineTokenizer(LineTokenizer tokenizer) { diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/FieldSetMapper.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/FieldSetMapper.java index 39cebc3a8..a4727086a 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/FieldSetMapper.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/FieldSetMapper.java @@ -17,6 +17,7 @@ package org.springframework.batch.item.file.mapping; + /** * Interface that is used to map data obtained from a {@link FieldSet} into an * object. @@ -27,5 +28,10 @@ package org.springframework.batch.item.file.mapping; */ public interface FieldSetMapper { - T process(FieldSet fieldSet); + /** + * Method used to map data obtained from a {@link FieldSet} into an object. + * + * @param fieldSet the {@link FieldSet} to map + */ + T map(FieldSet fieldSet); } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapper.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapper.java index 6a457e108..994cb1a6a 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapper.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapper.java @@ -31,7 +31,7 @@ public class PassThroughFieldSetMapper implements FieldSetMapper
{ * org.springframework.batch.io.file.FieldSetMapper#mapLine(org.springframework * .batch.io.file.FieldSet) */ - public FieldSet process(FieldSet fs) { + public FieldSet map(FieldSet fs) { return fs; } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/AbstractLineTokenizer.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/AbstractLineTokenizer.java index f04f80dfd..bbf677550 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/AbstractLineTokenizer.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/AbstractLineTokenizer.java @@ -64,7 +64,7 @@ public abstract class AbstractLineTokenizer implements LineTokenizer { * * @return the resulting tokens */ - public FieldSet process(String line) { + public FieldSet tokenize(String line) { if(line == null){ line = ""; diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/DelimitedLineAggregator.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/DelimitedLineAggregator.java index 03f39702b..d7543f374 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/DelimitedLineAggregator.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/DelimitedLineAggregator.java @@ -36,7 +36,7 @@ public class DelimitedLineAggregator implements LineAggregator { /* (non-Javadoc) * @see org.springframework.batch.item.file.transform.LineAggregator#aggregate(java.lang.Object) */ - public String process(T[] item) { + public String aggregate(T[] item) { return StringUtils.arrayToDelimitedString(item, delimiter); } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/FormatterLineAggregator.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/FormatterLineAggregator.java index 5c0450c14..8e9a7657e 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/FormatterLineAggregator.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/FormatterLineAggregator.java @@ -94,7 +94,7 @@ public class FormatterLineAggregator implements LineAggregator { * @param item data to be aggregated * @return aggregated string */ - public String process(T item) { + public String aggregate(T item) { Assert.notNull(item); Assert.notNull(format); diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineAggregator.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineAggregator.java index 188557375..151008697 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineAggregator.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineAggregator.java @@ -16,9 +16,6 @@ package org.springframework.batch.item.file.transform; - - - /** * Interface used to create string representing object. * @@ -26,5 +23,11 @@ package org.springframework.batch.item.file.transform; */ public interface LineAggregator { - String process(T item); + /** + * Create a string from the value provided. + * + * @param item values to be converted + * @return string + */ + String aggregate(T item); } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineTokenizer.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineTokenizer.java index 609e6f1a8..dfcfb7290 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineTokenizer.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/LineTokenizer.java @@ -18,7 +18,6 @@ package org.springframework.batch.item.file.transform; import org.springframework.batch.item.file.mapping.FieldSet; - /** * Interface that is used by framework to split string obtained typically from a * file into tokens. @@ -28,5 +27,13 @@ import org.springframework.batch.item.file.mapping.FieldSet; */ public interface LineTokenizer { - FieldSet process(String line); + /** + * Yields the tokens resulting from the splitting of the supplied + * line. + * + * @param line the line to be tokenized (can be null) + * + * @return the resulting tokens + */ + FieldSet tokenize(String line); } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PassThroughLineAggregator.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PassThroughLineAggregator.java index 442472a1a..dffb2fb62 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PassThroughLineAggregator.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PassThroughLineAggregator.java @@ -6,9 +6,9 @@ public class PassThroughLineAggregator implements LineAggregator { /** * Simply convert to a String with toString(). * - * @see org.springframework.batch.item.file.transform.LineAggregator#process(java.lang.Object) + * @see org.springframework.batch.item.file.transform.LineAggregator#aggregate(java.lang.Object) */ - public String process(T item) { + public String aggregate(T item) { return item.toString(); } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizer.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizer.java index 480fd089e..c765e7916 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizer.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizer.java @@ -31,7 +31,7 @@ public class PrefixMatchingCompositeLineTokenizer implements LineTokenizer { this.tokenizers = new LinkedHashMap(tokenizers); } - public FieldSet process(String line) { + public FieldSet tokenize(String line) { if (line == null) { return new DefaultFieldSet(new String[0]); @@ -61,7 +61,7 @@ public class PrefixMatchingCompositeLineTokenizer implements LineTokenizer { throw new IllegalStateException("Could not match record to tokenizer for line=[" + line + "]"); } - return tokenizer.process(line); + return tokenizer.tokenize(line); } } diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/RecursiveCollectionLineAggregator.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/RecursiveCollectionLineAggregator.java index 81cf5b5df..1d5cef1c7 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/RecursiveCollectionLineAggregator.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/transform/RecursiveCollectionLineAggregator.java @@ -31,10 +31,10 @@ public class RecursiveCollectionLineAggregator implements LineAggregator items) { + public String aggregate(Collection items) { StringBuilder builder = new StringBuilder(); for (T value : items) { - builder.append(delegate.process(value) + LINE_SEPARATOR); + builder.append(delegate.aggregate(value) + LINE_SEPARATOR); } return builder.delete(builder.length()-LINE_SEPARATOR.length(),builder.length()).toString(); } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/FlatFileItemWriterTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/FlatFileItemWriterTests.java index 9f9760463..db608ead2 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/FlatFileItemWriterTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/FlatFileItemWriterTests.java @@ -148,7 +148,7 @@ public class FlatFileItemWriterTests { @Test public void testWriteWithConverter() throws Exception { writer.setLineAggregator(new LineAggregator() { - public String process(String item) { + public String aggregate(String item) { return "FOO:" + item; } }); @@ -168,7 +168,7 @@ public class FlatFileItemWriterTests { @Test public void testWriteWithConverterAndString() throws Exception { writer.setLineAggregator(new LineAggregator() { - public String process(String item) { + public String aggregate(String item) { return "FOO:" + item; } }); @@ -417,7 +417,7 @@ public class FlatFileItemWriterTests { writer.setLineAggregator(new LineAggregator() { - public String process(String item) { + public String aggregate(String item) { if (item.equals("2")) { throw new RuntimeException("aggregation failed on " + item); } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapperTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapperTests.java index eb262d791..6809ba6a5 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapperTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/BeanWrapperFieldSetMapperTests.java @@ -63,7 +63,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "This is some dummy string", "true", "C" }, new String[] { "varString", "varBoolean", "varChar" }); - TestObject result = mapper.process(fieldSet); + TestObject result = mapper.map(fieldSet); assertEquals("This is some dummy string", result.getVarString()); assertEquals(true, result.isVarBoolean()); assertEquals('C', result.getVarChar()); @@ -78,7 +78,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "This is some dummy string", "true", "C" }, new String[] { "varString", "varBoolean", "varChar" }); - TestObject result = mapper.process(fieldSet); + TestObject result = mapper.map(fieldSet); assertEquals("This is some dummy string", result.getVarString()); assertEquals(true, result.isVarBoolean()); assertEquals('C', result.getVarChar()); @@ -93,7 +93,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "This is some dummy string", "true", "C" }, new String[] { "VarString", "VAR_BOOLEAN", "VAR_CHAR" }); - TestObject result = mapper.process(fieldSet); + TestObject result = mapper.map(fieldSet); assertEquals("This is some dummy string", result.getVarString()); assertEquals(true, result.isVarBoolean()); assertEquals('C', result.getVarChar()); @@ -107,7 +107,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "This is some dummy string", "true", "C" }, new String[] { "varString", "varBoolean", "varChar" }); - TestObject result = mapper.process(fieldSet); + TestObject result = mapper.map(fieldSet); assertEquals("This is some dummy string", result.getVarString()); assertEquals(true, result.isVarBoolean()); assertEquals('C', result.getVarChar()); @@ -130,7 +130,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { new String[] { "This is some dummy string", "1", "Another dummy", "2" }, new String[] { "valueA", "valueB", "testObjectB.valueA", "testObjectB.testObjectC.value" }); - TestNestedA result = mapper.process(fieldSet); + TestNestedA result = mapper.map(fieldSet); assertEquals("This is some dummy string", result.getValueA()); assertEquals(1, result.getValueB()); @@ -150,7 +150,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "This is some dummy string", "1" }, new String[] { "VALUE_A", "VALUE_B" }); - TestNestedA result = (TestNestedA) mapper.process(fieldSet); + TestNestedA result = (TestNestedA) mapper.map(fieldSet); assertEquals("This is some dummy string", result.getValueA()); assertEquals(1, result.getValueB()); @@ -167,7 +167,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "1" }, new String[] { "foo" }); - TestNestedC result = mapper.process(fieldSet); + TestNestedC result = mapper.map(fieldSet); // "foo" is similar enough to "value" that it matches - but only because // nothing else does... @@ -189,7 +189,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "Another dummy", "2" }, new String[] { "TestObjectB.ValueA", "TestObjectB.TestObjectC.Value" }); - TestNestedA result = mapper.process(fieldSet); + TestNestedA result = mapper.map(fieldSet); assertEquals("Another dummy", result.getTestObjectB().getValueA()); assertEquals(2, result.getTestObjectB().getTestObjectC().getValue()); @@ -209,7 +209,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "Another dummy" }, new String[] { "TestObjectB.foo" }); try { - mapper.process(fieldSet); + mapper.map(fieldSet); fail("Expected NotWritablePropertyException"); } catch (NotWritablePropertyException e) { @@ -231,7 +231,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "2" }, new String[] { "TestObjectA.garbage" }); try { - mapper.process(fieldSet); + mapper.map(fieldSet); fail("Expected NotWritablePropertyException"); } catch (NotWritablePropertyException e) { @@ -271,7 +271,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { FieldSet fieldSet = new DefaultFieldSet(new String[] { "1", "2", "3" }, new String[] { "NestedC[0].Value", "NestedC[1].Value", "NestedC[2].Value" }); - mapper.process(fieldSet); + mapper.map(fieldSet); assertEquals(1, ((TestNestedC) nestedList.getNestedC().get(0)).getValue()); assertEquals(2, ((TestNestedC) nestedList.getNestedC().get(1)).getValue()); @@ -285,7 +285,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { mapper.setTargetType(TestObject.class); FieldSet fieldSet = new DefaultFieldSet(new String[] { "00009" }, new String[] { "varLong" }); - TestObject bean = (TestObject) mapper.process(fieldSet); + TestObject bean = (TestObject) mapper.map(fieldSet); // since Spring 2.5.5 this is OK (before that BATCH-261) assertEquals(9, bean.getVarLong()); } @@ -299,7 +299,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { mapper.setCustomEditors(Collections.singletonMap(Long.TYPE, new CustomNumberEditor(Long.class, NumberFormat .getNumberInstance(), true))); - TestObject bean = (TestObject) mapper.process(fieldSet); + TestObject bean = (TestObject) mapper.map(fieldSet); assertEquals(9, bean.getVarLong()); } @@ -313,7 +313,7 @@ public class BeanWrapperFieldSetMapperTests extends TestCase { mapper.setCustomEditors(Collections.singletonMap(Long.TYPE, new CustomNumberEditor(Long.class, NumberFormat .getNumberInstance(), true))); - TestObject bean = (TestObject) mapper.process(fieldSet); + TestObject bean = (TestObject) mapper.map(fieldSet); assertEquals(9, bean.getVarLong()); assertEquals(78, bean.getVarInt()); diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/DefaultLineMapperTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/DefaultLineMapperTests.java index 8b03846e4..ec2151e01 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/DefaultLineMapperTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/DefaultLineMapperTests.java @@ -20,12 +20,12 @@ public class DefaultLineMapperTests { final String item = "ITEM"; LineTokenizer tokenizer = createStrictMock(LineTokenizer.class); - expect(tokenizer.process(line)).andReturn(fs); + expect(tokenizer.tokenize(line)).andReturn(fs); replay(tokenizer); @SuppressWarnings("unchecked") FieldSetMapper fsMapper = createStrictMock(FieldSetMapper.class); - expect(fsMapper.process(fs)).andReturn(item); + expect(fsMapper.map(fs)).andReturn(item); replay(fsMapper); tested.setLineTokenizer(tokenizer); diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapperTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapperTests.java index 2842ad656..01c3ac8d1 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapperTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/mapping/PassThroughFieldSetMapperTests.java @@ -27,11 +27,11 @@ public class PassThroughFieldSetMapperTests extends TestCase { /** * Test method for - * {@link org.springframework.batch.item.file.mapping.PassThroughFieldSetMapper#process(org.springframework.batch.item.file.mapping.FieldSet)}. + * {@link org.springframework.batch.item.file.mapping.PassThroughFieldSetMapper#map(org.springframework.batch.item.file.mapping.FieldSet)}. */ public void testMapLine() { FieldSet fieldSet = new DefaultFieldSet(new String[] { "foo", "bar" }); - assertEquals(fieldSet, mapper.process(fieldSet)); + assertEquals(fieldSet, mapper.map(fieldSet)); } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineAggregatorTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineAggregatorTests.java index 5fc325e86..7c10a3445 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineAggregatorTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineAggregatorTests.java @@ -30,12 +30,12 @@ public class DelimitedLineAggregatorTests { @Test public void testSetDelimiter() { aggregator.setDelimiter(";"); - assertEquals("foo;bar", aggregator.process(new String[] { "foo", "bar" })); + assertEquals("foo;bar", aggregator.aggregate(new String[] { "foo", "bar" })); } @Test public void testAggregate() { - assertEquals("foo,bar", aggregator.process(new String[] { "foo", "bar" })); + assertEquals("foo,bar", aggregator.aggregate(new String[] { "foo", "bar" })); } } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineTokenizerTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineTokenizerTests.java index 41662067a..925d97488 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineTokenizerTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/DelimitedLineTokenizerTests.java @@ -27,7 +27,7 @@ public class DelimitedLineTokenizerTests extends TestCase { private DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer(); public void testTokenizeRegularUse() { - FieldSet tokens = tokenizer.process("sfd,\"Well,I have no idea what to do in the afternoon\",sFj, asdf,,as\n"); + FieldSet tokens = tokenizer.tokenize("sfd,\"Well,I have no idea what to do in the afternoon\",sFj, asdf,,as\n"); assertEquals(6, tokens.getFieldCount()); assertTrue(TOKEN_MATCHES, tokens.readString(0).equals("sfd")); assertTrue(TOKEN_MATCHES, tokens.readString(1).equals("Well,I have no idea what to do in the afternoon")); @@ -36,7 +36,7 @@ public class DelimitedLineTokenizerTests extends TestCase { assertTrue(TOKEN_MATCHES, tokens.readString(4).equals("")); assertTrue(TOKEN_MATCHES, tokens.readString(5).equals("as")); - tokens = tokenizer.process("First string,"); + tokens = tokenizer.tokenize("First string,"); assertEquals(2, tokens.getFieldCount()); assertTrue(TOKEN_MATCHES, tokens.readString(0).equals("First string")); assertTrue(TOKEN_MATCHES, tokens.readString(1).equals("")); @@ -53,13 +53,13 @@ public class DelimitedLineTokenizerTests extends TestCase { } public void testDelimitedLineTokenizer() { - FieldSet line = tokenizer.process("a,b,c"); + FieldSet line = tokenizer.tokenize("a,b,c"); assertEquals(3, line.getFieldCount()); } public void testNames() { tokenizer.setNames(new String[] {"A", "B", "C"}); - FieldSet line = tokenizer.process("a,b,c"); + FieldSet line = tokenizer.tokenize("a,b,c"); assertEquals(3, line.getFieldCount()); assertEquals("a", line.readString("A")); } @@ -67,7 +67,7 @@ public class DelimitedLineTokenizerTests extends TestCase { public void testTooFewNames() { tokenizer.setNames(new String[] {"A", "B"}); try { - tokenizer.process("a,b,c"); + tokenizer.tokenize("a,b,c"); fail("Expected IncorrectTokenCountException"); } catch (IncorrectTokenCountException e) { @@ -79,7 +79,7 @@ public class DelimitedLineTokenizerTests extends TestCase { public void testTooManyNames() { tokenizer.setNames(new String[] {"A", "B", "C", "D"}); try{ - tokenizer.process("a,b,c"); + tokenizer.tokenize("a,b,c"); } catch(IncorrectTokenCountException e){ assertEquals(4, e.getExpectedCount()); @@ -90,25 +90,25 @@ public class DelimitedLineTokenizerTests extends TestCase { public void testDelimitedLineTokenizerChar() { AbstractLineTokenizer tokenizer = new DelimitedLineTokenizer(' '); - FieldSet line = tokenizer.process("a b c"); + FieldSet line = tokenizer.tokenize("a b c"); assertEquals(3, line.getFieldCount()); } public void testTokenizeWithQuotes() { - FieldSet line = tokenizer.process("a,b,\"c\""); + FieldSet line = tokenizer.tokenize("a,b,\"c\""); assertEquals(3, line.getFieldCount()); assertEquals("c", line.readString(2)); } public void testTokenizeWithNotDefaultQuotes() { tokenizer.setQuoteCharacter('\''); - FieldSet line = tokenizer.process("a,b,'c'"); + FieldSet line = tokenizer.tokenize("a,b,'c'"); assertEquals(3, line.getFieldCount()); assertEquals("c", line.readString(2)); } public void testTokenizeWithEscapedQuotes() { - FieldSet line = tokenizer.process("a,\"\"b,\"\"\"c\""); + FieldSet line = tokenizer.tokenize("a,\"\"b,\"\"\"c\""); assertEquals(3, line.getFieldCount()); assertEquals("\"\"b", line.readString(1)); assertEquals("\"c", line.readString(2)); @@ -116,39 +116,39 @@ public class DelimitedLineTokenizerTests extends TestCase { public void testTokenizeWithUnclosedQuotes() { tokenizer.setQuoteCharacter('\''); - FieldSet line = tokenizer.process("a,\"b,c"); + FieldSet line = tokenizer.tokenize("a,\"b,c"); assertEquals(3, line.getFieldCount()); assertEquals("\"b", line.readString(1)); assertEquals("c", line.readString(2)); } public void testTokenizeWithSpaceAtEnd() { - FieldSet line = tokenizer.process("a,b,c "); + FieldSet line = tokenizer.tokenize("a,b,c "); assertEquals(3, line.getFieldCount()); assertEquals("c", line.readString(2)); } public void testTokenizeWithQuoteAndSpaceAtEnd() { - FieldSet line = tokenizer.process("a,b,\"c\" "); + FieldSet line = tokenizer.tokenize("a,b,\"c\" "); assertEquals(3, line.getFieldCount()); assertEquals("c", line.readString(2)); } public void testTokenizeWithQuoteAndSpaceBeforeDelimiter() { - FieldSet line = tokenizer.process("a,\"b\" ,c"); + FieldSet line = tokenizer.tokenize("a,\"b\" ,c"); assertEquals(3, line.getFieldCount()); assertEquals("b", line.readString(1)); } public void testTokenizeWithDelimiterAtEnd() { - FieldSet line = tokenizer.process("a,b,c,"); + FieldSet line = tokenizer.tokenize("a,b,c,"); assertEquals(4, line.getFieldCount()); assertEquals("c", line.readString(2)); assertEquals("", line.readString(3)); } public void testEmptyLine() throws Exception { - FieldSet line = tokenizer.process(""); + FieldSet line = tokenizer.tokenize(""); assertEquals(0, line.getFieldCount()); } @@ -156,7 +156,7 @@ public class DelimitedLineTokenizerTests extends TestCase { tokenizer.setNames(new String[]{"A", "B"}); try{ - tokenizer.process(""); + tokenizer.tokenize(""); } catch(IncorrectTokenCountException ex){ assertEquals(2, ex.getExpectedCount()); @@ -165,33 +165,33 @@ public class DelimitedLineTokenizerTests extends TestCase { } public void testWhitespaceLine() throws Exception { - FieldSet line = tokenizer.process(" "); + FieldSet line = tokenizer.tokenize(" "); // whitespace counts as text assertEquals(1, line.getFieldCount()); } public void testNullLine() throws Exception { - FieldSet line = tokenizer.process(null); + FieldSet line = tokenizer.tokenize(null); // null doesn't... assertEquals(0, line.getFieldCount()); } public void testMultiLineField() throws Exception { - FieldSet line = tokenizer.process("a,b,c\nrap"); + FieldSet line = tokenizer.tokenize("a,b,c\nrap"); assertEquals(3, line.getFieldCount()); assertEquals("c\nrap", line.readString(2)); } public void testMultiLineFieldWithQuotes() throws Exception { - FieldSet line = tokenizer.process("a,b,\"c\nrap\""); + FieldSet line = tokenizer.tokenize("a,b,\"c\nrap\""); assertEquals(3, line.getFieldCount()); assertEquals("c\nrap", line.readString(2)); } public void testTokenizeWithQuotesEmptyValue() { - FieldSet line = tokenizer.process("\"a\",\"b\",\"\",\"d\""); + FieldSet line = tokenizer.tokenize("\"a\",\"b\",\"\",\"d\""); assertEquals(4, line.getFieldCount()); assertEquals("", line.readString(2)); } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FixedLengthTokenizerTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FixedLengthTokenizerTests.java index 88c325d92..4583c6efb 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FixedLengthTokenizerTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FixedLengthTokenizerTests.java @@ -36,7 +36,7 @@ public class FixedLengthTokenizerTests { public void testTokenizeEmptyString() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 10), new Range(11, 15) }); try { - tokenizer.process(""); + tokenizer.tokenize(""); fail("Expected IncorrectLineLengthException"); } catch (IncorrectLineLengthException ex) { @@ -48,14 +48,14 @@ public class FixedLengthTokenizerTests { @Test public void testEmptyStringWithNoRanges() { tokenizer.setColumns(new Range[] {}); - tokenizer.process(""); + tokenizer.tokenize(""); } @Test public void testTokenizeSmallerStringThanRanges() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 10), new Range(11, 15) }); try { - tokenizer.process("12345"); + tokenizer.tokenize("12345"); fail("Expected IncorrectLineLengthException"); } catch (IncorrectLineLengthException ex) { @@ -68,7 +68,7 @@ public class FixedLengthTokenizerTests { @Test public void testTokenizeSmallerStringThanRangesWithWhitespace() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 10) }); - FieldSet tokens = tokenizer.process("12345 "); + FieldSet tokens = tokenizer.tokenize("12345 "); assertEquals("12345", tokens.readString(0)); assertEquals("", tokens.readString(1)); } @@ -77,7 +77,7 @@ public class FixedLengthTokenizerTests { public void testTokenizeSmallerStringThanRangesNotStrict() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 10) }); tokenizer.setStrict(false); - FieldSet tokens = tokenizer.process("12345"); + FieldSet tokens = tokenizer.tokenize("12345"); assertEquals("12345", tokens.readString(0)); assertEquals("", tokens.readString(1)); } @@ -85,7 +85,7 @@ public class FixedLengthTokenizerTests { @Test public void testTokenizeSmallerStringThanRangesWithWhitespaceOpenEnded() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6) }); - FieldSet tokens = tokenizer.process("12345 "); + FieldSet tokens = tokenizer.tokenize("12345 "); assertEquals("12345", tokens.readString(0)); assertEquals("", tokens.readString(1)); } @@ -94,7 +94,7 @@ public class FixedLengthTokenizerTests { public void testTokenizeNullString() { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 10), new Range(11, 15) }); try { - tokenizer.process(null); + tokenizer.tokenize(null); fail("Expected IncorrectLineLengthException"); } catch (IncorrectLineLengthException ex) { @@ -106,7 +106,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 2), new Range(3, 7), new Range(8, 12) }); // test shorter line as defined by record descriptor line = "H11234512345"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(3, tokens.getFieldCount()); assertEquals("H1", tokens.readString(0)); assertEquals("12345", tokens.readString(1)); @@ -118,7 +118,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 10), new Range(11, 25), new Range(26, 30) }); // test shorter line as defined by record descriptor line = "H1 12345678 12345"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(3, tokens.getFieldCount()); assertEquals(line.substring(0, 10).trim(), tokens.readString(0)); assertEquals(line.substring(10, 25).trim(), tokens.readString(1)); @@ -130,7 +130,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 10), new Range(11, 25), new Range(26, 30) }); line = "H1 12345678 1234567890"; try { - tokenizer.process(line); + tokenizer.tokenize(line); fail("Expected IncorrectLineLengthException"); } catch (IncorrectLineLengthException ex) { @@ -143,7 +143,7 @@ public class FixedLengthTokenizerTests { public void testLongerLinesOpenRange() throws Exception { tokenizer.setColumns(new Range[] { new Range(1, 10), new Range(11, 25), new Range(26) }); line = "H1 12345678 1234567890"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(line.substring(0, 10).trim(), tokens.readString(0)); assertEquals(line.substring(10, 25).trim(), tokens.readString(1)); assertEquals(line.substring(25).trim(), tokens.readString(2)); @@ -154,7 +154,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 10), new Range(11, 25), new Range(26,30) }); line = "H1 12345678 1234567890"; tokenizer.setStrict(false); - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(line.substring(0, 10).trim(), tokens.readString(0)); assertEquals(line.substring(10, 25).trim(), tokens.readString(1)); assertEquals(line.substring(25, 30).trim(), tokens.readString(2)); @@ -165,7 +165,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(14, 28), new Range(34, 38), new Range(1, 10) }); // test normal length line = "H1 +++12345678 +++++12345"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(3, tokens.getFieldCount()); assertEquals(line.substring(0, 10).trim(), tokens.readString(2)); assertEquals(line.substring(13, 28).trim(), tokens.readString(0)); @@ -177,7 +177,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 5), new Range(6, 15), new Range(16, 25), new Range(26, 27) }); // test another type of record line = "H2 123456 12345 12"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(4, tokens.getFieldCount()); assertEquals(line.substring(0, 5).trim(), tokens.readString(0)); assertEquals(line.substring(5, 15).trim(), tokens.readString(1)); @@ -191,7 +191,7 @@ public class FixedLengthTokenizerTests { new Range(34) }); // test another type of record line = "H2 123456 12345 12-123456"; - FieldSet tokens = tokenizer.process(line); + FieldSet tokens = tokenizer.tokenize(line); assertEquals(5, tokens.getFieldCount()); assertEquals(line.substring(0, 5).trim(), tokens.readString(0)); assertEquals(line.substring(5, 15).trim(), tokens.readString(1)); @@ -205,7 +205,7 @@ public class FixedLengthTokenizerTests { tokenizer.setColumns(new Range[] { new Range(1, 5) }); try { - tokenizer.process("12345"); + tokenizer.tokenize("12345"); fail("Exception was expected: too few names provided"); } catch (IncorrectTokenCountException e) { diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FormatterLineAggregatorTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FormatterLineAggregatorTests.java index 031ab05ff..a5f0928c1 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FormatterLineAggregatorTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/FormatterLineAggregatorTests.java @@ -39,7 +39,7 @@ public class FormatterLineAggregatorTests { String[] args = { "does not matter what is here" }; try { - aggregator.process(args); + aggregator.aggregate(args); fail("should not work with no format specified"); } catch (IllegalArgumentException expected) { @@ -56,7 +56,7 @@ public class FormatterLineAggregatorTests { aggregator.setMaximumLength(3); aggregator.setFormat("%3s"); try { - aggregator.process(args); + aggregator.aggregate(args); fail("Invalid text length, exception should have been thrown"); } catch (IllegalStateException expected) { @@ -71,7 +71,7 @@ public class FormatterLineAggregatorTests { public void testAggregate() { String[] args = { "Matchsize", "Smallsize" }; aggregator.setFormat("%9s%9s"); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals("MatchsizeSmallsize", result); } @@ -82,7 +82,7 @@ public class FormatterLineAggregatorTests { public void testAggregateWithLastRangeUnbound() { String[] args = { "Matchsize", "Smallsize" }; aggregator.setFormat("%-12s%s"); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals("Matchsize Smallsize", result); } @@ -93,7 +93,7 @@ public class FormatterLineAggregatorTests { public void testAggregateFormattedRight() { String[] args = { "Matchsize", "Smallsize" }; aggregator.setFormat("%13s%10s"); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals(23, result.length()); assertEquals(" Matchsize Smallsize", result); } @@ -127,7 +127,7 @@ public class FormatterLineAggregatorTests { } }); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals(" Matchsize Smallsize ", result); } @@ -160,7 +160,7 @@ public class FormatterLineAggregatorTests { } }); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals("Matchsize....Smallsize..", result); } @@ -171,7 +171,7 @@ public class FormatterLineAggregatorTests { public void testAggregateFormattedLeft() { String[] args = { "Matchsize", "Smallsize" }; aggregator.setFormat("%-13s%-11s"); - String result = aggregator.process(args); + String result = aggregator.aggregate(args); assertEquals("Matchsize Smallsize ", result); } @@ -183,6 +183,6 @@ public class FormatterLineAggregatorTests { public void testAggregateNullArgument() { String[] args = { null }; aggregator.setFormat("%3s"); - assertEquals(" ", aggregator.process(args)); + assertEquals(" ", aggregator.aggregate(args)); } } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PassThroughLineAggregatorTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PassThroughLineAggregatorTests.java index 513569400..ed0a28921 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PassThroughLineAggregatorTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PassThroughLineAggregatorTests.java @@ -11,11 +11,11 @@ public class PassThroughLineAggregatorTests extends TestCase { public void testUnmapItemAsFieldSet() throws Exception { Object item = new Object(); - assertEquals(item.toString(), mapper.process(item)); + assertEquals(item.toString(), mapper.aggregate(item)); } public void testUnmapItemAsString() throws Exception { - assertEquals("foo", mapper.process("foo")); + assertEquals("foo", mapper.aggregate("foo")); } } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizerTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizerTests.java index 4db0d2d8f..94cd93226 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizerTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/PrefixMatchingCompositeLineTokenizerTests.java @@ -32,7 +32,7 @@ public class PrefixMatchingCompositeLineTokenizerTests extends TestCase { public void testNoTokenizers() throws Exception { try { - tokenizer.process("a line"); + tokenizer.tokenize("a line"); fail("Expected IllegalStateException"); } catch (IllegalStateException e) { // expected @@ -41,7 +41,7 @@ public class PrefixMatchingCompositeLineTokenizerTests extends TestCase { public void testNullLine() throws Exception { tokenizer.setTokenizers(Collections.singletonMap("foo", (LineTokenizer) new DelimitedLineTokenizer())); - FieldSet fields = tokenizer.process(null); + FieldSet fields = tokenizer.tokenize(null); assertEquals(0, fields.getFieldCount()); } @@ -49,12 +49,12 @@ public class PrefixMatchingCompositeLineTokenizerTests extends TestCase { Map map = new HashMap(); map.put("", new DelimitedLineTokenizer()); map.put("foo", new LineTokenizer() { - public FieldSet process(String line) { + public FieldSet tokenize(String line) { return null; } }); tokenizer.setTokenizers(map); - FieldSet fields = tokenizer.process("abc"); + FieldSet fields = tokenizer.tokenize("abc"); assertEquals(1, fields.getFieldCount()); } @@ -62,20 +62,20 @@ public class PrefixMatchingCompositeLineTokenizerTests extends TestCase { Map map = new LinkedHashMap(); map.put("", new LineTokenizer() { - public FieldSet process(String line) { + public FieldSet tokenize(String line) { return null; } }); map.put("foo", new DelimitedLineTokenizer()); tokenizer.setTokenizers(map); - FieldSet fields = tokenizer.process("foo,bar"); + FieldSet fields = tokenizer.tokenize("foo,bar"); assertEquals("bar", fields.readString(1)); } public void testNoMatch() throws Exception { tokenizer.setTokenizers(Collections.singletonMap("foo", (LineTokenizer) new DelimitedLineTokenizer())); try { - tokenizer.process("nomatch"); + tokenizer.tokenize("nomatch"); fail("Expected IllegalStateException"); } catch (IllegalStateException e) { // expected @@ -84,11 +84,11 @@ public class PrefixMatchingCompositeLineTokenizerTests extends TestCase { public void testMatchWithPrefix() throws Exception { tokenizer.setTokenizers(Collections.singletonMap("foo", (LineTokenizer) new LineTokenizer() { - public FieldSet process(String line) { + public FieldSet tokenize(String line) { return new DefaultFieldSet(new String[] {line}); } })); - FieldSet fields = tokenizer.process("foo bar"); + FieldSet fields = tokenizer.tokenize("foo bar"); assertEquals(1, fields.getFieldCount()); assertEquals("foo bar", fields.readString(0)); } diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/RecursiveCollectionItemTransformerTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/RecursiveCollectionItemTransformerTests.java index a2e8bc8ec..0b933b82f 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/RecursiveCollectionItemTransformerTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/file/transform/RecursiveCollectionItemTransformerTests.java @@ -34,15 +34,15 @@ public class RecursiveCollectionItemTransformerTests extends TestCase { public void testSetDelegateAndPassInString() throws Exception { aggregator.setDelegate(new LineAggregator() { - public String process(String item) { + public String aggregate(String item) { return "bar"; } }); - assertEquals("bar", aggregator.process(Collections.singleton("foo"))); + assertEquals("bar", aggregator.aggregate(Collections.singleton("foo"))); } public void testTransformList() throws Exception { - String result = aggregator.process(Arrays.asList(StringUtils.commaDelimitedListToStringArray("foo,bar"))); + String result = aggregator.aggregate(Arrays.asList(StringUtils.commaDelimitedListToStringArray("foo,bar"))); String[] array = StringUtils.delimitedListToStringArray(result, LINE_SEPARATOR); assertEquals("foo", array[0]); assertEquals("bar", array[1]); diff --git a/spring-batch-infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java b/spring-batch-infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java index be298372b..68a52aafc 100644 --- a/spring-batch-infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java +++ b/spring-batch-infrastructure/src/test/java/org/springframework/batch/repeat/support/AbstractTradeBatchTests.java @@ -67,7 +67,7 @@ public abstract class AbstractTradeBatchTests extends TestCase { } protected static class TradeMapper implements FieldSetMapper { - public Trade process(FieldSet fs) { + public Trade map(FieldSet fs) { return new Trade(fs); } } diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/GameFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/GameFieldSetMapper.java index 5e5eeb0f8..aa3bda7ea 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/GameFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/GameFieldSetMapper.java @@ -6,7 +6,7 @@ import org.springframework.batch.sample.domain.football.Game; public class GameFieldSetMapper implements FieldSetMapper { - public Game process(FieldSet fs) { + public Game map(FieldSet fs) { if(fs == null){ return null; diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/PlayerFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/PlayerFieldSetMapper.java index 68c43ee24..fffabaf20 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/PlayerFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/football/internal/PlayerFieldSetMapper.java @@ -6,7 +6,7 @@ import org.springframework.batch.sample.domain.football.Player; public class PlayerFieldSetMapper implements FieldSetMapper { - public Player process(FieldSet fs) { + public Player map(FieldSet fs) { if(fs == null){ return null; diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapper.java index 7eb115148..fd533c352 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapper.java @@ -83,7 +83,7 @@ public class AggregateItemFieldSetMapper implements FieldSetMapper process(FieldSet fieldSet) { + public AggregateItem map(FieldSet fieldSet) { if (fieldSet.readString(0).equals(begin)) { return AggregateItem.getHeader(); @@ -92,7 +92,7 @@ public class AggregateItemFieldSetMapper implements FieldSetMapper(delegate.process(fieldSet)); + return new AggregateItem(delegate.map(fieldSet)); } diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/AddressFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/AddressFieldSetMapper.java index 2aed512ca..dcf777b24 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/AddressFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/AddressFieldSetMapper.java @@ -33,7 +33,7 @@ public class AddressFieldSetMapper implements FieldSetMapper
{ public static final String COUNTRY_COLUMN = "COUNTRY"; - public Address process(FieldSet fieldSet) { + public Address map(FieldSet fieldSet) { Address address = new Address(); address.setAddressee(fieldSet.readString(ADDRESSEE_COLUMN)); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/BillingFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/BillingFieldSetMapper.java index 06e28ec1c..d4dc288a8 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/BillingFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/BillingFieldSetMapper.java @@ -27,7 +27,7 @@ public class BillingFieldSetMapper implements FieldSetMapper { public static final String PAYMENT_TYPE_ID_COLUMN = "PAYMENT_TYPE_ID"; public static final String PAYMENT_DESC_COLUMN = "PAYMENT_DESC"; - public BillingInfo process(FieldSet fieldSet) { + public BillingInfo map(FieldSet fieldSet) { BillingInfo info = new BillingInfo(); info.setPaymentId(fieldSet.readString(PAYMENT_TYPE_ID_COLUMN)); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/CustomerFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/CustomerFieldSetMapper.java index d45fed4ed..d59c77a62 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/CustomerFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/CustomerFieldSetMapper.java @@ -34,7 +34,7 @@ public class CustomerFieldSetMapper implements FieldSetMapper { public static final String REG_ID_COLUMN = "REG_ID"; public static final String VIP_COLUMN = "VIP"; - public Customer process(FieldSet fieldSet) { + public Customer map(FieldSet fieldSet) { Customer customer = new Customer(); if (Customer.LINE_ID_BUSINESS_CUST.equals(fieldSet.readString(LINE_ID_COLUMN))) { diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/HeaderFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/HeaderFieldSetMapper.java index 42eaefe3f..77b9ea3fd 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/HeaderFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/HeaderFieldSetMapper.java @@ -27,7 +27,7 @@ public class HeaderFieldSetMapper implements FieldSetMapper { public static final String ORDER_ID_COLUMN = "ORDER_ID"; public static final String ORDER_DATE_COLUMN = "ORDER_DATE"; - public Order process(FieldSet fieldSet) { + public Order map(FieldSet fieldSet) { Order order = new Order(); order.setOrderId(fieldSet.readLong(ORDER_ID_COLUMN)); order.setOrderDate(fieldSet.readDate(ORDER_DATE_COLUMN)); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemFieldSetMapper.java index 2e9946cc8..f2b890ab3 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemFieldSetMapper.java @@ -33,7 +33,7 @@ public class OrderItemFieldSetMapper implements FieldSetMapper { public static final String ITEM_ID_COLUMN = "ITEM_ID"; - public LineItem process(FieldSet fieldSet) { + public LineItem map(FieldSet fieldSet) { LineItem item = new LineItem(); item.setItemId(fieldSet.readLong(ITEM_ID_COLUMN)); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemReader.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemReader.java index 77346dc9a..98aefd2ef 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemReader.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderItemReader.java @@ -89,7 +89,7 @@ public class OrderItemReader implements ItemReader { // start a new Order if (Order.LINE_ID_HEADER.equals(lineId)) { log.debug("STARTING NEW RECORD"); - order = headerMapper.process(fieldSet); + order = headerMapper.map(fieldSet); return; } @@ -114,7 +114,7 @@ public class OrderItemReader implements ItemReader { log.debug("MAPPING CUSTOMER"); if (order.getCustomer() == null) { - order.setCustomer(customerMapper.process(fieldSet)); + order.setCustomer(customerMapper.map(fieldSet)); order.getCustomer().setBusinessCustomer(true); } @@ -125,7 +125,7 @@ public class OrderItemReader implements ItemReader { log.debug("MAPPING CUSTOMER"); if (order.getCustomer() == null) { - order.setCustomer(customerMapper.process(fieldSet)); + order.setCustomer(customerMapper.map(fieldSet)); order.getCustomer().setBusinessCustomer(false); } @@ -134,25 +134,25 @@ public class OrderItemReader implements ItemReader { if (Address.LINE_ID_BILLING_ADDR.equals(lineId)) { log.debug("MAPPING BILLING ADDRESS"); - order.setBillingAddress(addressMapper.process(fieldSet)); + order.setBillingAddress(addressMapper.map(fieldSet)); return; } if (Address.LINE_ID_SHIPPING_ADDR.equals(lineId)) { log.debug("MAPPING SHIPPING ADDRESS"); - order.setShippingAddress(addressMapper.process(fieldSet)); + order.setShippingAddress(addressMapper.map(fieldSet)); return; } if (BillingInfo.LINE_ID_BILLING_INFO.equals(lineId)) { log.debug("MAPPING BILLING INFO"); - order.setBilling(billingMapper.process(fieldSet)); + order.setBilling(billingMapper.map(fieldSet)); return; } if (ShippingInfo.LINE_ID_SHIPPING_INFO.equals(lineId)) { log.debug("MAPPING SHIPPING INFO"); - order.setShipping(shippingMapper.process(fieldSet)); + order.setShipping(shippingMapper.map(fieldSet)); return; } @@ -162,7 +162,7 @@ public class OrderItemReader implements ItemReader { if (order.getLineItems() == null) { order.setLineItems(new ArrayList()); } - order.getLineItems().add(itemMapper.process(fieldSet)); + order.getLineItems().add(itemMapper.map(fieldSet)); return; } diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderProcessor.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderProcessor.java index c9e9301f0..2405e82f1 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderProcessor.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/OrderProcessor.java @@ -50,18 +50,18 @@ public class OrderProcessor implements ItemProcessor> { List result = new ArrayList(); - result.add(getAggregator("header").process(OrderFormatterUtils.headerArgs(order))); - result.add(getAggregator("customer").process(OrderFormatterUtils.customerArgs(order))); - result.add(getAggregator("address").process(OrderFormatterUtils.billingAddressArgs(order))); - result.add(getAggregator("billing").process(OrderFormatterUtils.billingInfoArgs(order))); + result.add(getAggregator("header").aggregate(OrderFormatterUtils.headerArgs(order))); + result.add(getAggregator("customer").aggregate(OrderFormatterUtils.customerArgs(order))); + result.add(getAggregator("address").aggregate(OrderFormatterUtils.billingAddressArgs(order))); + result.add(getAggregator("billing").aggregate(OrderFormatterUtils.billingInfoArgs(order))); List items = order.getLineItems(); for (LineItem lineItem : items) { - result.add(getAggregator("item").process(OrderFormatterUtils.lineItemArgs(lineItem))); + result.add(getAggregator("item").aggregate(OrderFormatterUtils.lineItemArgs(lineItem))); } - result.add(getAggregator("footer").process(OrderFormatterUtils.footerArgs(order))); + result.add(getAggregator("footer").aggregate(OrderFormatterUtils.footerArgs(order))); return result; } diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/ShippingFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/ShippingFieldSetMapper.java index bb38b85fc..1ff81a519 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/ShippingFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/order/internal/ShippingFieldSetMapper.java @@ -28,7 +28,7 @@ public class ShippingFieldSetMapper implements FieldSetMapper { public static final String SHIPPING_TYPE_ID_COLUMN = "SHIPPING_TYPE_ID"; public static final String SHIPPER_ID_COLUMN = "SHIPPER_ID"; - public ShippingInfo process(FieldSet fieldSet) { + public ShippingInfo map(FieldSet fieldSet) { ShippingInfo info = new ShippingInfo(); info.setShipperId(fieldSet.readString(SHIPPER_ID_COLUMN)); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizer.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizer.java index be65eb97f..954482963 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizer.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizer.java @@ -26,11 +26,11 @@ public class CompositeCustomerUpdateLineTokenizer extends StepExecutionListenerS /* (non-Javadoc) * @see org.springframework.batch.item.file.transform.LineTokenizer#tokenize(java.lang.String) */ - public FieldSet process(String line) { + public FieldSet tokenize(String line) { if(line.charAt(0) == 'F'){ //line starts with F, so the footer tokenizer should tokenize it. - FieldSet fs = footerTokenizer.process(line); + FieldSet fs = footerTokenizer.tokenize(line); long customerUpdateTotal = stepExecution.getReadCount(); long fileUpdateTotal = fs.readLong(1); if(customerUpdateTotal != fileUpdateTotal){ @@ -45,7 +45,7 @@ public class CompositeCustomerUpdateLineTokenizer extends StepExecutionListenerS } else if(line.charAt(0) == 'A' || line.charAt(0) == 'U' || line.charAt(0) == 'D'){ //line starts with A,U, or D, so it must be a customer operation. - return customerTokenizer.process(line); + return customerTokenizer.tokenize(line); } else{ //If the line doesn't start with any of the characters above, it must obviously be invalid. diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CustomerUpdateFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CustomerUpdateFieldSetMapper.java index 29d4bd019..cfe55b710 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CustomerUpdateFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/CustomerUpdateFieldSetMapper.java @@ -16,7 +16,7 @@ import org.springframework.batch.item.file.mapping.FieldSetMapper; */ public class CustomerUpdateFieldSetMapper implements FieldSetMapper { - public CustomerUpdate process(FieldSet fs) { + public CustomerUpdate map(FieldSet fs) { CustomerOperation operation = CustomerOperation.fromCode(fs.readChar(0)); String name = fs.readString(1); diff --git a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/internal/TradeFieldSetMapper.java b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/internal/TradeFieldSetMapper.java index ffb7f374f..93d037794 100644 --- a/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/internal/TradeFieldSetMapper.java +++ b/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/trade/internal/TradeFieldSetMapper.java @@ -29,7 +29,7 @@ public class TradeFieldSetMapper implements FieldSetMapper { public static final int PRICE_COLUMN = 2; public static final int CUSTOMER_COLUMN = 3; - public Trade process(FieldSet fieldSet) { + public Trade map(FieldSet fieldSet) { Trade trade = new Trade(); trade.setIsin(fieldSet.readString(ISIN_COLUMN)); diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapperTests.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapperTests.java index b527c5163..db73d8f07 100644 --- a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapperTests.java +++ b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/multiline/AggregateItemFieldSetMapperTests.java @@ -17,26 +17,26 @@ public class AggregateItemFieldSetMapperTests { @Test public void testDefaultBeginRecord() throws Exception { - assertTrue(mapper.process(new DefaultFieldSet(new String[] { "BEGIN" })).isHeader()); - assertFalse(mapper.process(new DefaultFieldSet(new String[] { "BEGIN" })).isFooter()); + assertTrue(mapper.map(new DefaultFieldSet(new String[] { "BEGIN" })).isHeader()); + assertFalse(mapper.map(new DefaultFieldSet(new String[] { "BEGIN" })).isFooter()); } @Test public void testSetBeginRecord() throws Exception { mapper.setBegin("FOO"); - assertTrue(mapper.process(new DefaultFieldSet(new String[] { "FOO" })).isHeader()); + assertTrue(mapper.map(new DefaultFieldSet(new String[] { "FOO" })).isHeader()); } @Test public void testDefaultEndRecord() throws Exception { - assertFalse(mapper.process(new DefaultFieldSet(new String[] { "END" })).isHeader()); - assertTrue(mapper.process(new DefaultFieldSet(new String[] { "END" })).isFooter()); + assertFalse(mapper.map(new DefaultFieldSet(new String[] { "END" })).isHeader()); + assertTrue(mapper.map(new DefaultFieldSet(new String[] { "END" })).isFooter()); } @Test public void testSetEndRecord() throws Exception { mapper.setEnd("FOO"); - assertTrue(mapper.process(new DefaultFieldSet(new String[] { "FOO" })).isFooter()); + assertTrue(mapper.map(new DefaultFieldSet(new String[] { "FOO" })).isFooter()); } @Test @@ -53,11 +53,11 @@ public class AggregateItemFieldSetMapperTests { @Test public void testDelegate() throws Exception { mapper.setDelegate(new FieldSetMapper() { - public String process(FieldSet fs) { + public String map(FieldSet fs) { return "foo"; } }); - assertEquals("foo", mapper.process(new DefaultFieldSet(new String[] { "FOO" })).getItem()); + assertEquals("foo", mapper.map(new DefaultFieldSet(new String[] { "FOO" })).getItem()); } diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/order/OrderItemReaderTests.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/order/OrderItemReaderTests.java index 031dccd68..403d10272 100644 --- a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/order/OrderItemReaderTests.java +++ b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/order/OrderItemReaderTests.java @@ -84,13 +84,13 @@ public class OrderItemReaderTests { // create mock mapper FieldSetMapper mapper = createMock(FieldSetMapper.class); // set how mapper should respond - set return values for mapper - expect(mapper.process(headerFS)).andReturn(order); - expect(mapper.process(customerFS)).andReturn(customer); - expect(mapper.process(billingFS)).andReturn(billing); - expect(mapper.process(shippingFS)).andReturn(shipping); - expect(mapper.process(billingInfoFS)).andReturn(billingInfo); - expect(mapper.process(shippingInfoFS)).andReturn(shippingInfo); - expect(mapper.process(itemFS)).andReturn(item).times(3); + expect(mapper.map(headerFS)).andReturn(order); + expect(mapper.map(customerFS)).andReturn(customer); + expect(mapper.map(billingFS)).andReturn(billing); + expect(mapper.map(shippingFS)).andReturn(shipping); + expect(mapper.map(billingInfoFS)).andReturn(billingInfo); + expect(mapper.map(shippingInfoFS)).andReturn(shippingInfo); + expect(mapper.map(itemFS)).andReturn(item).times(3); replay(mapper); // set-up provider: set mappers diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizerTests.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizerTests.java index be0403d94..7e3d5ff30 100644 --- a/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizerTests.java +++ b/spring-batch-samples/src/test/java/org/springframework/batch/sample/domain/trade/CompositeCustomerUpdateLineTokenizerTests.java @@ -36,7 +36,7 @@ public class CompositeCustomerUpdateLineTokenizerTests { public void testCustomerAdd() throws Exception{ String customerAddLine = "AFDASFDASFDFSA"; - FieldSet fs = compositeTokenizer.process(customerAddLine); + FieldSet fs = compositeTokenizer.tokenize(customerAddLine); assertEquals(customerFieldSet, fs); assertEquals(customerAddLine, customerTokenizer.getTokenizedLine()); } @@ -45,7 +45,7 @@ public class CompositeCustomerUpdateLineTokenizerTests { public void testCustomerDelete() throws Exception{ String customerAddLine = "DFDASFDASFDFSA"; - FieldSet fs = compositeTokenizer.process(customerAddLine); + FieldSet fs = compositeTokenizer.tokenize(customerAddLine); assertEquals(customerFieldSet, fs); assertEquals(customerAddLine, customerTokenizer.getTokenizedLine()); } @@ -54,7 +54,7 @@ public class CompositeCustomerUpdateLineTokenizerTests { public void testCustomerUpdate() throws Exception{ String customerAddLine = "UFDASFDASFDFSA"; - FieldSet fs = compositeTokenizer.process(customerAddLine); + FieldSet fs = compositeTokenizer.tokenize(customerAddLine); assertEquals(customerFieldSet, fs); assertEquals(customerAddLine, customerTokenizer.getTokenizedLine()); } @@ -63,7 +63,7 @@ public class CompositeCustomerUpdateLineTokenizerTests { public void testInvalidLine() throws Exception{ String invalidLine = "INVALID"; - compositeTokenizer.process(invalidLine); + compositeTokenizer.tokenize(invalidLine); } @@ -76,7 +76,7 @@ public class CompositeCustomerUpdateLineTokenizerTests { this.fieldSetToReturn = fieldSetToReturn; } - public FieldSet process(String line) { + public FieldSet tokenize(String line) { this.tokenizedLine = line; return fieldSetToReturn; } diff --git a/spring-batch-samples/src/test/java/org/springframework/batch/sample/support/AbstractFieldSetMapperTests.java b/spring-batch-samples/src/test/java/org/springframework/batch/sample/support/AbstractFieldSetMapperTests.java index 11940f74b..844a2b1ab 100644 --- a/spring-batch-samples/src/test/java/org/springframework/batch/sample/support/AbstractFieldSetMapperTests.java +++ b/spring-batch-samples/src/test/java/org/springframework/batch/sample/support/AbstractFieldSetMapperTests.java @@ -38,7 +38,7 @@ public abstract class AbstractFieldSetMapperTests { */ @Test public void testRegularUse() throws Exception { - assertEquals(expectedDomainObject(), fieldSetMapper().process(fieldSet())); + assertEquals(expectedDomainObject(), fieldSetMapper().map(fieldSet())); } }