public class AmqpItemReader<T> extends java.lang.Object implements ItemReader<T>
AmqpTemplate
を使用してメッセージを受信および / または変換する AMQP ItemReader
実装。
コンストラクターと説明 |
---|
AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate) AmqpItemReader を初期化します。 |
修飾子と型 | メソッドと説明 |
---|---|
T | read() 入力データの一部を読み取り、次のデータに進みます。 |
void | setItemType(java.lang.Class<? extends T> itemType) リーダーの itemType を確立します。 |
public AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
amqpTemplate
- 使用するテンプレート。null であってはなりません。@Nullable public T read()
ItemReader
null
を返す必要があります。トランザクション設定では、最初の呼び出しがロールバックされたトランザクション内にあった場合、呼び出し元は連続した呼び出し(またはそれ以外)から同じアイテムを 2 回取得する場合があります。ItemReader<T>
の read
null
public void setItemType(java.lang.Class<? extends T> itemType)
itemType
- リーダーによって返されるクラス型。