クラス ChunkProcessorChunkRequestHandler<S>

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

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

    • ChunkProcessorChunkRequestHandler

      public ChunkProcessorChunkRequestHandler()

  • メソッドの詳細

    • afterPropertiesSet

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

    • setChunkProcessor

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

    • handle

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

Copyright © 2026 Spring. All rights reserved.