フィールドの詳細

• logger

  protected final org.apache.commons.logging.Log logger

コンストラクターの詳細

• JsrFaultTolerantChunkProcessor

  public JsrFaultTolerantChunkProcessor(ItemReader<? extends I> reader,
                                        ItemProcessor<? super I,? extends O> processor,
                                        ItemWriter<? super O> writer,
                                        RepeatOperations repeatTemplate,
                                        BatchRetryTemplate batchRetryTemplate)

メソッドの詳細

• setSkipPolicy

  public void setSkipPolicy(SkipPolicy skipPolicy)

  パラメーター:

  skipPolicy - SkipPolicy

• setRollbackClassifier

  public void setRollbackClassifier(org.springframework.classify.Classifier<java.lang.Throwable,java.lang.Boolean> rollbackClassifier)

  パラメーター:

  rollbackClassifier - Classifier

• setChunkMonitor

  public void setChunkMonitor(ChunkMonitor chunkMonitor)

  パラメーター:

  chunkMonitor - ChunkMonitor

• setListeners

  public void setListeners(java.util.List<? extends StepListener> listeners)

  いくつかの StepListener をハンドラーに登録します。それぞれが正しい段階で指定された順序でコールバックを取得します。

  オーバーライド:

  クラス JsrChunkProcessor<I, O> の setListeners 

  パラメーター:

  listeners - 登録するリスナー

• registerListener

  public void registerListener(StepListener listener)

  プロセスの適切な段階でコールバックのリスナーを登録します。

  オーバーライド:

  クラス JsrChunkProcessor<I, O> の registerListener 

  パラメーター:

  listener - StepListener

• provide

  protected I provide(StepContribution contribution,
                      Chunk<I> chunk)
               throws java.lang.Exception

  チャンクループの読み取りフェーズに再試行およびスキップロジックを追加します。

  オーバーライド:

  クラス JsrChunkProcessor<I, O> の provide 

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  戻り値:

  アイテムです

  例外:

  java.lang.Exception - エラーが発生した場合にスローされます。

• transform

  protected O transform(StepContribution contribution,
                        I item)
                 throws java.lang.Exception

  チャンクループのプロセスフェーズに再試行およびスキップロジックを追加します。

  オーバーライド:

  クラス JsrChunkProcessor<I, O> の transform 

  パラメーター:

  contribution - StepContribution

  item - 処理するアイテム

  戻り値:

  O プロセッサーが利用可能な場合に処理されたアイテム

  例外:

  java.lang.Exception - エラーが発生した場合にスローされます。

• persist

  protected void persist(StepContribution contribution,
                         Chunk<O> chunk)
                  throws java.lang.Exception

  チャンクループの書き込みフェーズに再試行およびスキップロジックを追加します。

  オーバーライド:

  クラス JsrChunkProcessor<I, O> の persist 

  パラメーター:

  contribution - StepContribution

  chunk - Chunk

  例外:

  java.lang.Exception - エラーが発生した場合にスローされます。