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

Implement onSkipInWrite for delegate to handle

Browse Source 
Fixes TCK tests: testChunkSkipWrite and testChunkSkipWriteExceedSkip
This commit is contained in:
Chris Schaefer
2013-12-18 13:54:07 -05:00
parent 681c1dccd9
commit 6d26e40cc8
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-batch-core/src/main/java/org/springframework/batch/core/jsr/SkipListenerAdapter.java
View File

@@ -7,8 +7,9 @@ import javax.batch.operations.BatchRuntimeException;
import org.springframework.batch.core.SkipListener;
public class SkipListenerAdapter<T, S> implements SkipListener<T, S> {
import java.util.List;
public class SkipListenerAdapter<T, S> implements SkipListener<T, S> {
private final SkipReadListener skipReadDelegate;
private final SkipProcessListener skipProcessDelegate;
private final SkipWriteListener skipWriteDelegate;
@@ -32,7 +33,13 @@ public class SkipListenerAdapter<T, S> implements SkipListener<T, S> {
@Override
public void onSkipInWrite(S item, Throwable t) {
//TODO: This will take more than just wrapping...
if(skipWriteDelegate != null && t instanceof Exception) {
try {
skipWriteDelegate.onSkipWriteItem((List<Object>) item, (Exception) t);
} catch (Exception e) {
throw new BatchRuntimeException(e);
}
}
}
@Override