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

OPEN - issue BATCH-385: Merge user attributes in StepContext with ExecutionContext

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

Last delegating ItemStream tidied up.
This commit is contained in:
dsyer
2008-02-29 13:27:34 +00:00
parent 20445128ff
commit 256574358b
1 changed files with 1 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/writer/DelegatingItemWriter.java
View File

@@ -1,12 +1,8 @@
package org.springframework.batch.item.writer;
import org.springframework.batch.item.ExecutionContext;
import org.springframework.batch.item.ItemStream;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.exception.ClearFailedException;
import org.springframework.batch.item.exception.FlushFailedException;
import org.springframework.batch.item.exception.StreamException;
import org.springframework.batch.item.stream.ItemStreamSupport;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.util.Assert;
@@ -16,12 +12,10 @@ import org.springframework.util.Assert;
* @author Dave Syer
* @author Robert Kasanicky
*/
public class DelegatingItemWriter implements ItemWriter, ItemStream, InitializingBean {
public class DelegatingItemWriter implements ItemWriter, InitializingBean {
private ItemWriter writer;
private ItemStream stream;
/**
* Calls {@link #doProcess(Object)} and then writes the result to the
* delegate {@link ItemWriter}.
@@ -48,11 +42,6 @@ public class DelegatingItemWriter implements ItemWriter, ItemStream, Initializin
*/
public void setDelegate(ItemWriter writer) {
this.writer = writer;
if (writer instanceof ItemStream) {
this.stream = (ItemStream) writer;
} else {
this.stream = new ItemStreamSupport();
}
}
public void afterPropertiesSet() throws Exception {
@@ -73,26 +62,4 @@ public class DelegatingItemWriter implements ItemWriter, ItemStream, Initializin
writer.flush();
}
/**
* @throws StreamException
* @see org.springframework.batch.item.ItemStream#close(ExecutionContext)
*/
public void close(ExecutionContext executionContext) throws StreamException {
stream.close(null);
}
/**
* @see org.springframework.batch.item.ExecutionContextProvider#update(ExecutionContext)
*/
public void update(ExecutionContext executionContext) {
stream.update(executionContext);
}
/**
* @throws StreamException
* @see org.springframework.batch.item.ItemStream#open()
*/
public void open(ExecutionContext executionContext) throws StreamException {
stream.open(executionContext);
}
}