RESOLVED - issue BATCH-455: Pass object to ItemWriteListener.afterWrite()

This commit is contained in:
dsyer
2008-03-13 22:18:10 +00:00
parent e3615676e1
commit 68562a3b29
7 changed files with 13 additions and 11 deletions

View File

@@ -36,8 +36,9 @@ public interface ItemWriteListener extends BatchListener {
* Called after {@link ItemWriter#write(Object) If the item is last in a
* chunk, this will be called before any transaction is committed, and
* before {@link ChunkListener#afterChunk()}
* @param item TODO
*/
void afterWrite();
void afterWrite(Object item);
/**
* Called if an error occurs while trying to write.

View File

@@ -85,7 +85,7 @@ public class BatchListenerSupport implements StepListener, ChunkListener,
/* (non-Javadoc)
* @see org.springframework.batch.core.domain.ItemWriteListener#afterWrite()
*/
public void afterWrite() {
public void afterWrite(Object item) {
}
/* (non-Javadoc)

View File

@@ -51,10 +51,10 @@ public class CompositeItemWriteListener implements ItemWriteListener {
}
}
public void afterWrite() {
public void afterWrite(Object item) {
for (Iterator iterator = listeners.iterator(); iterator.hasNext();) {
ItemWriteListener listener = (ItemWriteListener) iterator.next();
listener.afterWrite();
listener.afterWrite(item);
}
}

View File

@@ -31,7 +31,7 @@ public class ItemListenerSupport implements ItemWriteListener, ItemReadListener
/* (non-Javadoc)
* @see org.springframework.batch.core.domain.ItemWriteListener#afterWrite()
*/
public void afterWrite() {
public void afterWrite(Object item) {
}
/* (non-Javadoc)

View File

@@ -146,10 +146,10 @@ public class MulticasterBatchListener implements StepListener, ChunkListener, It
/**
*
* @see org.springframework.batch.core.listener.CompositeItemWriteListener#afterWrite()
* @see org.springframework.batch.core.listener.CompositeItemWriteListener#afterWrite(Object)
*/
public void afterWrite() {
itemWriteListener.afterWrite();
public void afterWrite(Object item) {
itemWriteListener.afterWrite(item);
}
/**

View File

@@ -98,7 +98,7 @@ class BatchListenerFactoryHelper {
try {
multicaster.beforeWrite(item);
super.write(item);
multicaster.afterWrite();
multicaster.afterWrite(item);
}
catch (Exception e) {
multicaster.onWriteError(e, item);