Class AmqpItemReader<T>
- java.lang.Object
- org.springframework.batch.item.amqp.AmqpItemReader<T>
- All Implemented Interfaces:
ItemReader<T>
public class AmqpItemReader<T> extends java.lang.Object implements ItemReader<T>
AMQP
ItemReader
implementation using anAmqpTemplate
to receive and/or convert messages.- Author:
- Chris Schaefer, Mahmoud Ben Hassine
Constructor Summary
Constructors Constructor Description AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
Initialize the AmqpItemReader.
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
read()
Reads a piece of input data and advance to the next one.void
setItemType(java.lang.Class<? extends T> itemType)
Establish the itemType for the reader.
Method Detail
read
public T read()
Description copied from interface:ItemReader
Reads a piece of input data and advance to the next one. Implementations must returnnull
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 interfaceItemReader<T>
- Returns:
- T the item to be processed or
null
if the data source is exhausted
setItemType
public void setItemType(java.lang.Class<? extends T> itemType)
Establish the itemType for the reader.- Parameters:
itemType
- class type that will be returned by the reader.