Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

OPEN - issue BATCH-320: Refactor ItemWriter as primary collaborator (with wrapper for processor)

Browse Source 
http://jira.springframework.org/browse/BATCH-320

Compiler warnings.
This commit is contained in:
dsyer
2008-01-29 09:25:01 +00:00
parent b0c6a16879
commit a98f0e566c
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-batch-samples/src/test/java/org/springframework/batch/sample/MultilineJobFunctionalTests.java
View File

@@ -23,17 +23,20 @@ import org.springframework.util.StringUtils;
public class MultilineJobFunctionalTests extends AbstractValidatingBatchLauncherTests {
private static final String EXPECTED_RESULT =
"[Trade: [isin=UK21341EAH45,quantity=978,price=98.34,customer=customer1], Trade: [isin=UK21341EAH46,quantity=112,price=18.12,customer=customer2]]" +
"[Trade: [isin=UK21341EAH47,quantity=245,price=12.78,customer=customer2], Trade: [isin=UK21341EAH48,quantity=108,price=9.25,customer=customer3], Trade: [isin=UK21341EAH49,quantity=854,price=23.39,customer=customer4]]";
// TODO: make the output group together in two lines, instead of all the
// trades coming out on a single line (it's the recursive transform call in
// FlatFileItemWriter).
private static final String EXPECTED_RESULT = "Trade: [isin=UK21341EAH45,quantity=978,price=98.34,customer=customer1]Trade: [isin=UK21341EAH46,quantity=112,price=18.12,customer=customer2]"
+ "Trade: [isin=UK21341EAH47,quantity=245,price=12.78,customer=customer2]Trade: [isin=UK21341EAH48,quantity=108,price=9.25,customer=customer3]Trade: [isin=UK21341EAH49,quantity=854,price=23.39,customer=customer4]";
private Resource output = new FileSystemResource("target/test-outputs/20070122.testStream.multilineStep.txt");
protected String[] getConfigLocations() {
return new String[] {"jobs/multilineJob.xml"};
return new String[] { "jobs/multilineJob.xml" };
}
protected void validatePostConditions() throws Exception {
// assertEquals(EXPECTED_RESULT, StringUtils.replace(IOUtils.toString(output.getInputStream()), System.getProperty("line.separator"), ""));
assertEquals(EXPECTED_RESULT, StringUtils.replace(IOUtils.toString(output.getInputStream()), System
.getProperty("line.separator"), ""));
}
}