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

クラス RemoteChunkHandlerFactoryBean<T>

java.lang.ObjectSE
org.springframework.batch.integration.chunk.RemoteChunkHandlerFactoryBean<T>
実装されたすべてのインターフェース:
org.springframework.beans.factory.FactoryBean<ChunkHandler<T>>
public class RemoteChunkHandlerFactoryBean<T> extends ObjectSE implements org.springframework.beans.factory.FactoryBean<ChunkHandler<T>>
既存のチャンク指向のステップも リモートチャンクマネージャーに変換するチャンクハンドラー用の便利なファクトリ Bean。アイデアは、ローカルで動作するステップから既存のチャンクプロセッサーを持ち上げ、チャンクをメッセージチャネルに書き込むものに置き換えることです。既存のステップは、そのビジネスチャンク処理の責任を、ファクトリによって生成されたハンドラーに引き渡します。このハンドラーは、チャンクが送信されるチャネルの反対側で ワーカーとして設定する必要があります。このチャンクハンドラーがインストールされると、アプリケーションは問題のステップの リモートチャンキングパターンでマネージャーと ワーカーリスナーの両方のロールを果たします。
作成者:
Dave Syer, Mahmoud Ben Hassine

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

    • RemoteChunkHandlerFactoryBean

      public RemoteChunkHandlerFactoryBean()

  • メソッドの詳細

    • setStep

      public void setStep(TaskletStep step)
      リモートチャンクマネージャーに変換されるローカルステップ。
      パラメーター:
      step - 設定するステップ

    • setChunkWriter

      public void setChunkWriter(ItemWriter<T> chunkWriter)
      ステップに注入されるアイテムライター。その責任は、アイテムのチャンクをリモートワーカーに送信することです。通常、実際には ChunkMessageChannelItemWriter になります。
      パラメーター:
      chunkWriter - 設定するチャンクライター

    • setStepContributionSource

      public void setStepContributionSource(StepContributionSource stepContributionSource)
      リモートワーカーから戻ってくる StepContribution インスタンスのソース。
      パラメーター:
      stepContributionSource - 設定するステップ貢献ソース (デフォルトはチャンクライターです)

    • getObjectType

      public ClassSE<?> getObjectType()
      このファクトリによって作成されたオブジェクトの型。ChunkHandler クラスを返します。
      次で指定:
      インターフェース org.springframework.beans.factory.FactoryBean<T> の getObjectType 
      関連事項:
      • FactoryBean.getObjectType()

    • isSingleton

      public boolean isSingleton()
      Bean ファクトリの最適化（常に true を返します）。
      次で指定:
      インターフェース org.springframework.beans.factory.FactoryBean<T> の isSingleton 
      関連事項:
      • FactoryBean.isSingleton()

    • getObject

      public ChunkHandler<T> getObject() throws ExceptionSE
      提供された step から抽出された ChunkProcessor から ChunkHandler を構築します。また、chunk writer を介してチャンクハンドラーにチャンクを送信するようにステップを変更します。
      次で指定:
      インターフェース org.springframework.beans.factory.FactoryBean<T> の getObject 
      例外:
      ExceptionSE
      関連事項:
      • FactoryBean.getObject()

    • updateStepContribution

      protected void updateStepContribution(StepContribution contribution, StepContributionSource stepContributionSource)
      StepContributionSource からのすべてのデータで StepContribution を更新します。フィルターと書き込みカウントに加えて終了ステータスが更新され、ソースのデータが反映されます。
      パラメーター:
      contribution - 現在の貢献
      stepContributionSource - StepContributions のソース