org.springframework.batch.sample.support
Class ExceptionThrowingItemReaderProxy<T>

java.lang.Object
  org.springframework.batch.sample.support.ExceptionThrowingItemReaderProxy<T>

All Implemented Interfaces:

ItemReader<T>

public class ExceptionThrowingItemReaderProxy<T>
extends Object
implements ItemReader<T>

Hacked ItemReader that throws exception on a given record number (useful for testing restart).

Author:

Robert Kasanicky, Lucas Ward

Constructor Summary

ExceptionThrowingItemReaderProxy()

Method Summary

T	read() Reads a piece of input data and advance to the next one.
void	setDelegate(ItemReader<T> delegate)
void	setThrowExceptionOnRecordNumber(int throwExceptionOnRecordNumber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExceptionThrowingItemReaderProxy

public ExceptionThrowingItemReaderProxy()

Method Detail

setThrowExceptionOnRecordNumber

public void setThrowExceptionOnRecordNumber(int throwExceptionOnRecordNumber)

Parameters:

throwExceptionOnRecordNumber - The number of record on which exception should be thrown

read

public T read()
       throws Exception

Description copied from interface: ItemReader

Reads a piece of input data and advance to the next one. Implementations must return null at the end of the input data set. In a transactional setting, caller might get the same item twice from successive calls (or otherwise), if the first call was in a transaction that rolled back.

Specified by:

read in interface ItemReader<T>

Throws:

Exception - if an underlying resource is unavailable.

setDelegate

public void setDelegate(ItemReader<T> delegate)