パッケージ org.springframework.batch.item.amqp

クラス AmqpItemReader<T>

java.lang.ObjectSE
org.springframework.batch.item.amqp.AmqpItemReader<T>
実装されたすべてのインターフェース:
ItemReader<T>
public class AmqpItemReader<T> extends ObjectSE implements ItemReader<T>

AmqpTemplate を使用してメッセージを受信および / または変換する AMQP ItemReader 実装。

デリゲート AmqpTemplate 実装がスレッドセーフである限り、このリーダーはスレッドセーフです。

作成者:
Chris Schaefer, Mahmoud Ben Hassine

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
    AmqpItemReader を初期化します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    T
    read()
    入力データの一部を読み取り、次のデータに進みます。
    void
    setItemType(ClassSE<? extends T> itemType)
    リーダー用の itemType を確立します。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • コンストラクターの詳細

    • AmqpItemReader

      public AmqpItemReader(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
      AmqpItemReader を初期化します。
      パラメーター:
      amqpTemplate - 使用するテンプレート。null であってはなりません。

  • メソッドの詳細

    • read

      @Nullable public T read()
      インターフェースからコピーされた説明: ItemReader
      入力データの一部を読み取り、次のデータに進みます。実装は、入力データセットの最後に null を返す必要があります。トランザクション設定では、最初の呼び出しがロールバックされたトランザクション内にあった場合、呼び出し元は連続した呼び出し（またはそれ以外）から同じアイテムを 2 回取得する場合があります。
      次で指定:
      インターフェース ItemReader<T> の read 
      戻り値:
      T 処理するアイテム、またはデータソースが使い果たされた場合は null 

    • setItemType

      public void setItemType(ClassSE<? extends T> itemType)
      リーダー用の itemType を確立します。
      パラメーター:
      itemType - リーダーによって返されるクラス型。