public class StepListenerSupport<T,S> extends java.lang.Object implements StepExecutionListener, ChunkListener, ItemReadListener<T>, ItemProcessListener<T,S>, ItemWriteListener<S>, SkipListener<T,S>
StepListener
インターフェースの基本的な何もしない実装。ROLLBACK_EXCEPTION_KEY
コンストラクターと説明 |
---|
StepListenerSupport() |
修飾子と型 | メソッドと説明 |
---|---|
void | afterChunk(ChunkContext context) トランザクションの外部で、チャンクが実行された後のコールバック。 |
void | afterChunkError(ChunkContext context) チャンクがロールバック用にマークされた後のコールバック。 |
void | afterProcess(T item, S result) ItemProcessor.process(Object) が戻った後に呼び出されます。 |
void | afterRead(T item) ItemReader.read() の後に呼び出されます。 |
ExitStatus | afterStep(StepExecution stepExecution) リスナーにステップの終了ステータスを変更する機会を与えます。 |
void | afterWrite(java.util.List<? extends S> items) ItemWriter.write(java.util.List) の後に呼び出されるこれは、トランザクションがコミットされる前、および ChunkListener.afterChunk(ChunkContext) の前に呼び出されます |
void | beforeChunk(ChunkContext context) チャンクが実行される前の、トランザクション内のコールバック。 |
void | beforeProcess(T item) ItemProcessor.process(Object) の前に呼び出されます。 |
void | beforeRead() ItemReader.read() の前に呼び出されます |
void | beforeStep(StepExecution stepExecution) 現在のスコープの StepExecution を使用して、リスナーの状態を初期化します。 |
void | beforeWrite(java.util.List<? extends S> items) ItemWriter.write(java.util.List) の前に呼び出されます |
void | onProcessError(T item, java.lang.Exception e) ItemProcessor.process(Object) から例外がスローされた場合に呼び出されます。 |
void | onReadError(java.lang.Exception ex) 読み取りの試行中にエラーが発生した場合に呼び出されます。 |
void | onSkipInProcess(T item, java.lang.Throwable t) このアイテムは、指定された例外で処理に失敗し、スキップが要求されました。 |
void | onSkipInRead(java.lang.Throwable t) 読み取りの失敗に対するコールバックは正当であるため、再スローされません。 |
void | onSkipInWrite(S item, java.lang.Throwable t) この項目は、指定された例外で書き込み時に失敗し、スキップが要求されました。 |
void | onWriteError(java.lang.Exception exception, java.util.List<? extends S> items) 書き込みの試行中にエラーが発生した場合に呼び出されます。 |
@Nullable public ExitStatus afterStep(StepExecution stepExecution)
StepExecutionListener
ExitStatus.and(ExitStatus)
を使用して通常の終了ステータスと結合されます。ステップの処理ロジックの実行後に呼び出されます(成功または失敗の両方)。このメソッドで例外をスローしても効果はなく、ログに記録されるだけです。StepExecutionListener
の afterStep
stepExecution
- StepExecution
インスタンス。ExitStatus
。null
を返し、古い値を変更せずに残します。public void beforeStep(StepExecution stepExecution)
StepExecutionListener
StepExecution
を使用して、リスナーの状態を初期化します。StepExecutionListener
の beforeStep
stepExecution
- StepExecution
のインスタンス。public void afterChunk(ChunkContext context)
ChunkListener
ChunkListener
の afterChunk
context
- 現在の ChunkContext
public void beforeChunk(ChunkContext context)
ChunkListener
ChunkListener
の beforeChunk
context
- 現在の ChunkContext
public void afterRead(T item)
ItemReadListener
ItemReader.read()
の後に呼び出されます。このメソッドは、実際のアイテムに対してのみ呼び出されます(つまり、リーダーが null を返す場合は呼び出されません)。ItemReadListener<T>
の afterRead
item
- read() から返された public void beforeRead()
ItemReadListener
ItemReader.read()
の前に呼び出されます ItemReadListener<T>
の beforeRead
public void onReadError(java.lang.Exception ex)
ItemReadListener
ItemReadListener<T>
の onReadError
ex
- ItemReader
からスロー public void afterWrite(java.util.List<? extends S> items)
ItemWriteListener
ItemWriter.write(java.util.List)
の後に呼び出されるこれは、トランザクションがコミットされる前、および ChunkListener.afterChunk(ChunkContext)
の前に呼び出されます ItemWriteListener<S>
の afterWrite
items
- 書かれたアイテム public void beforeWrite(java.util.List<? extends S> items)
ItemWriteListener
ItemWriter.write(java.util.List)
の前に呼び出されます ItemWriteListener<S>
の beforeWrite
items
- 書かれる public void onWriteError(java.lang.Exception exception, java.util.List<? extends S> items)
ItemWriteListener
ItemWriteListener<S>
の onWriteError
exception
- ItemWriter
からスロー items
- 書こうとしました。public void afterProcess(T item, @Nullable S result)
ItemProcessListener
ItemProcessor.process(Object)
が戻った後に呼び出されます。プロセッサーが null
を返す場合、このメソッドは {code null} の結果で呼び出され、「フィルター済み」アイテムの通知が可能になります。ItemProcessListener<T, S>
の afterProcess
item
- 処理される result
- 処理 public void beforeProcess(T item)
ItemProcessListener
ItemProcessor.process(Object)
の前に呼び出されます。ItemProcessListener<T, S>
の beforeProcess
item
- 処理されます。public void onProcessError(T item, java.lang.Exception e)
ItemProcessListener
ItemProcessor.process(Object)
から例外がスローされた場合に呼び出されます。ItemProcessListener<T, S>
の onProcessError
item
- 処理しようとしました e
- - 処理中にスローされた例外。public void onSkipInProcess(T item, java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInProcess
item
- 失敗したアイテム t
- 失敗の原因 public void onSkipInRead(java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInRead
t
- 失敗の原因 public void onSkipInWrite(S item, java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInWrite
item
- 失敗したアイテム t
- 失敗の原因 public void afterChunkError(ChunkContext context)
ChunkListener
ChunkListener
の afterChunkError
context
- 基になるロールバックを引き起こした例外を含むチャンクコンテキスト。