public class AmqpItemReader<T> extends java.lang.Object implements ItemReader<T>
AMQP ItemReader
implementation using an AmqpTemplate
to
receive and/or convert messages.
Constructor and Description |
---|
AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
Modifier and Type | Method and Description |
---|---|
T |
read()
Reads a piece of input data and advance to the next one.
|
void |
setItemType(java.lang.Class<? extends T> itemType) |
public AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public T read()
ItemReader
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.read
in interface ItemReader<T>
public void setItemType(java.lang.Class<? extends T> itemType)