org.springframework.batch.sample.domain.multiline

Class AggregateItemReader<T>

java.lang.Object

org.springframework.batch.sample.domain.multiline.AggregateItemReader<T>

All Implemented Interfaces:

org.springframework.batch.item.ItemReader<List<T>>

public class AggregateItemReader<T>
extends Object
implements org.springframework.batch.item.ItemReader<List<T>>

An ItemReader that delivers a list as its item, storing up objects from the injected ItemReader until they are ready to be packed out as a collection. This class must be used as a wrapper for a custom ItemReader that can identify the record boundaries. The custom reader should mark the beginning and end of records by returning an AggregateItem which responds true to its query methods is*().

This class is thread safe (it can be used concurrently by multiple threads) as long as the ItemReader is also thread safe.

Author:

Dave Syer

See Also:

AggregateItem.isHeader(), AggregateItem.isFooter()

Constructor Summary

Constructors

Constructor and Description
AggregateItemReader()

Method Summary

Methods

Modifier and Type	Method and Description
List<T>	read() Get the next list of records.
void	setItemReader(org.springframework.batch.item.ItemReader<AggregateItem<T>> itemReader)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateItemReader

public AggregateItemReader()

Method Detail

read

public List<T> read()
             throws Exception

Get the next list of records.

Specified by:

read in interface org.springframework.batch.item.ItemReader<List<T>>

Throws:

Exception

See Also:

ItemReader.read()

setItemReader

public void setItemReader(org.springframework.batch.item.ItemReader<AggregateItem<T>> itemReader)