パッケージ org.springframework.batch.integration.chunk

クラス ChunkProcessorChunkHandler<S>

java.lang.ObjectSE
org.springframework.batch.integration.chunk.ChunkProcessorChunkHandler<S>
型パラメーター:
S - 処理されるチャンク内のアイテムの型
実装されたすべてのインターフェース:
ChunkHandler<S>, org.springframework.beans.factory.InitializingBean
@MessageEndpoint public class ChunkProcessorChunkHandler<S> extends ObjectSE implements ChunkHandler<S>, org.springframework.beans.factory.InitializingBean
ChunkProcessor に基づく ChunkHandler。フォールトトレラントなプロセッサーとそうでないプロセッサーを区別する方法を知っています。プロセッサーがフォールトトレラントである場合、ロールバックが発生し、リクエストが再配信されることを前提として、例外を伝播できます。
作成者:
Dave Syer, Michael Minella, Mahmoud Ben Hassine

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

    • ChunkProcessorChunkHandler

      public ChunkProcessorChunkHandler()

  • メソッドの詳細

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      例外:
      ExceptionSE

    • setChunkProcessor

      public void setChunkProcessor(ChunkProcessor<S> chunkProcessor)
      ChunkProcessor のパブリック setter。
      パラメーター:
      chunkProcessor - 設定する chunkProcessor

    • handleChunk

      @ServiceActivator public ChunkResponse handleChunk(ChunkRequest<S> chunkRequest) throws ExceptionSE
      インターフェースからコピーされた説明: ChunkHandler
      チャンクを処理し、すべてのアイテムを処理して、結果を要約したレスポンスを返します。結果が失敗の場合、レスポンスはそのように言う必要があります。ハンドラーは、トランザクションをロールバックする必要があり、リクエストが再配信されることを知っている場合にのみ例外をスローします（同じハンドラーにない場合は、同じステップを処理する 1 つに）。
      次で指定:
      インターフェース ChunkHandler<S> の handleChunk 
      パラメーター:
      chunkRequest - 処理するチャンクを含むリクエスト
      戻り値:
      結果を要約したレスポンス
      例外:
      ExceptionSE - ハンドラーがトランザクションをロールバックし、チャンクを再配信する必要がある場合
      関連事項: