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()
ItemReadernull 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)