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

RESOLVED - issue BATCH-513: CompositeItemReadListener, CompositeItemWriteListener using ChunkListeners?

Browse Source 
Changed signature of methods
This commit is contained in:
dsyer
2008-03-26 06:41:44 +00:00
parent 08ceb9d962
commit f690e39440
4 changed files with 25 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-batch-core/src/main/java/org/springframework/batch/core/listener/CompositeItemReadListener.java
View File

@@ -20,7 +20,6 @@ import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import org.springframework.batch.core.ChunkListener;
import org.springframework.batch.core.ItemReadListener;
/**
@@ -34,10 +33,10 @@ public class CompositeItemReadListener implements ItemReadListener {
/**
* Public setter for the listeners.
*
* @param listeners
* @param itemReadListeners
*/
public void setListeners(ChunkListener[] listeners) {
this.listeners = Arrays.asList(listeners);
public void setListeners(ItemReadListener[] itemReadListeners) {
this.listeners = Arrays.asList(itemReadListeners);
}
/**

7
spring-batch-core/src/main/java/org/springframework/batch/core/listener/CompositeItemWriteListener.java
View File

@@ -20,7 +20,6 @@ import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import org.springframework.batch.core.ChunkListener;
import org.springframework.batch.core.ItemWriteListener;
/**
@@ -34,10 +33,10 @@ public class CompositeItemWriteListener implements ItemWriteListener {
/**
* Public setter for the listeners.
*
* @param listeners
* @param itemWriteListeners
*/
public void setListeners(ChunkListener[] listeners) {
this.listeners = Arrays.asList(listeners);
public void setListeners(ItemWriteListener[] itemWriteListeners) {
this.listeners = Arrays.asList(itemWriteListeners);
}
/**

9
spring-batch-core/src/test/java/org/springframework/batch/core/listener/CompositeItemReadListenerTests.java
View File

@@ -64,4 +64,13 @@ public class CompositeItemReadListenerTests extends TestCase {
compositeListener.onReadError(ex);
listenerControl.verify();
}
public void testSetListners() throws Exception {
compositeListener.setListeners(new ItemReadListener[] {listener});
listener.beforeRead();
listenerControl.replay();
compositeListener.beforeRead();
listenerControl.verify();
}
}

11
spring-batch-core/src/test/java/org/springframework/batch/core/listener/CompositeItemWriteListenerTests.java
View File

@@ -19,7 +19,6 @@ import junit.framework.TestCase;
import org.easymock.MockControl;
import org.springframework.batch.core.ItemWriteListener;
import org.springframework.batch.core.listener.CompositeItemWriteListener;
/**
* @author Lucas Ward
@@ -64,4 +63,14 @@ public class CompositeItemWriteListenerTests extends TestCase {
compositeListener.onWriteError(ex, item);
listenerControl.verify();
}
public void testSetListners() throws Exception {
compositeListener.setListeners(new ItemWriteListener[] {listener});
Object item = new Object();
listener.beforeWrite(item);
listenerControl.replay();
compositeListener.beforeWrite(item);
listenerControl.verify();
}
}