クラス MulticasterBatchListener<T,S>

メソッドの詳細

• setListeners

  public void setListeners(ListSE<? extends StepListener> listeners)

  各オブジェクトをリスナーとして登録します。登録されると、MulticasterBatchListener の呼び出しは個々のリスナーにブロードキャストされます。

  パラメーター:

  listeners - マルチキャスターに知られている型のリスナーオブジェクト。

• register

  public void register(StepListener listener)

  実装された適切なインターフェースでコールバックのリスナーを登録します。StepListener または ItemStream を提供できます。他の型は無視されます。

  パラメーター:

  listener - 登録する StepListener インスタンス。

• afterProcess

  public void afterProcess(T item, @Nullable S result)

  インターフェースからコピーされた説明: ItemProcessListener

  ItemProcessor.process(Object) が戻った後に呼び出されます。プロセッサーが null を返した場合でも、このメソッドは null の結果で呼び出され、「フィルター処理された」アイテムの通知を可能にします。

  次で指定:

  インターフェース ItemProcessListener<T,S> の afterProcess 

  パラメーター:

  item - 処理される

  result - 処理

  関連事項:

  • CompositeItemProcessListener.afterProcess(java.lang.Object, java.lang.Object)

• beforeProcess

  public void beforeProcess(T item)

  インターフェースからコピーされた説明: ItemProcessListener

  ItemProcessor.process(Object) の前に呼び出されます。

  次で指定:

  インターフェース ItemProcessListener<T,S> の beforeProcess 

  パラメーター:

  item - 処理されます。

  関連事項:

  • CompositeItemProcessListener.beforeProcess(java.lang.Object)

• onProcessError

  public void onProcessError(T item, ExceptionSE ex)

  インターフェースからコピーされた説明: ItemProcessListener

  ItemProcessor.process(Object) から例外がスローされた場合に呼び出されます。

  次で指定:

  インターフェース ItemProcessListener<T,S> の onProcessError 

  パラメーター:

  item - 処理しようとしました

  ex - - 処理中にスローされた例外。

  関連事項:

  • CompositeItemProcessListener.onProcessError(java.lang.Object, java.lang.Exception)

• afterStep

  @Nullable public ExitStatus afterStep(StepExecution stepExecution)

  インターフェースからコピーされた説明: StepExecutionListener

  リスナーにステップの終了ステータスを変更する機会を与えます。返された値は、ExitStatus.and(ExitStatus) を使用して通常の終了ステータスと結合されます。

  ステップの処理ロジックの実行後に (成功または失敗に関係なく) 呼び出されます。このメソッドで例外をスローしても、ログに記録されるだけなので効果はありません。

  次で指定:

  インターフェース StepExecutionListener の afterStep 

  パラメーター:

  stepExecution - StepExecution インスタンス。

  戻り値:

  通常の値と組み合わせる ExitStatus。古い値を変更しない場合は、null (デフォルト) を返します。

  関連事項:

  • CompositeStepExecutionListener.afterStep(StepExecution)

• beforeStep

  public void beforeStep(StepExecution stepExecution)

  インターフェースからコピーされた説明: StepExecutionListener

  現在のスコープの StepExecution を使用して、リスナーの状態を初期化します。

  次で指定:

  インターフェース StepExecutionListener の beforeStep 

  パラメーター:

  stepExecution - StepExecution のインスタンス。

  関連事項:

  • CompositeStepExecutionListener.beforeStep(org.springframework.batch.core.StepExecution)

• afterChunk

  public void afterChunk(ChunkContext context)

  インターフェースからコピーされた説明: ChunkListener

  トランザクションの外部で、チャンクが実行された後のコールバック。

  次で指定:

  インターフェース ChunkListener の afterChunk 

  パラメーター:

  context - 現在の ChunkContext

  関連事項:

  • CompositeChunkListener.afterChunk(ChunkContext context)

• beforeChunk

  public void beforeChunk(ChunkContext context)

  インターフェースからコピーされた説明: ChunkListener

  チャンクが実行される前の、トランザクション内のコールバック。

  次で指定:

  インターフェース ChunkListener の beforeChunk 

  パラメーター:

  context - 現在の ChunkContext

  関連事項:

  • CompositeChunkListener.beforeChunk(ChunkContext context)

• afterRead

  public void afterRead(T item)

  インターフェースからコピーされた説明: ItemReadListener

  ItemReader.read() の後に呼び出されます。このメソッドは、実際のアイテムに対してのみ呼び出されます (つまり、リーダーが null を返すときは呼び出されません)。

  次で指定:

  インターフェース ItemReadListener<T> の afterRead 

  パラメーター:

  item - read() から返された

  関連事項:

  • CompositeItemReadListener.afterRead(java.lang.Object)

• beforeRead

  public void beforeRead()

  インターフェースからコピーされた説明: ItemReadListener

  ItemReader.read() の前に呼び出されます

  次で指定:

  インターフェース ItemReadListener<T> の beforeRead 

  関連事項:

  • CompositeItemReadListener.beforeRead()

• onReadError

  public void onReadError(ExceptionSE ex)

  インターフェースからコピーされた説明: ItemReadListener

  読み取りの試行中にエラーが発生した場合に呼び出されます。

  次で指定:

  インターフェース ItemReadListener<T> の onReadError 

  パラメーター:

  ex - ItemReader からスロー

  関連事項:

  • CompositeItemReadListener.onReadError(java.lang.Exception)

• afterWrite

  public void afterWrite(Chunk<? extends S> items)

  インターフェースからコピーされた説明: ItemWriteListener

  ItemWriter.write(Chunk) の後に呼び出されます。これは、トランザクションがコミットされる前、および ChunkListener.afterChunk(ChunkContext) の前に呼び出されます。

  次で指定:

  インターフェース ItemWriteListener<T> の afterWrite 

  パラメーター:

  items - 書かれたアイテム

  関連事項:

  • ItemWriteListener.afterWrite(Chunk)

• beforeWrite

  public void beforeWrite(Chunk<? extends S> items)

  インターフェースからコピーされた説明: ItemWriteListener

  ItemWriter.write(Chunk) の前に呼び出されます

  次で指定:

  インターフェース ItemWriteListener<T> の beforeWrite 

  パラメーター:

  items - 書かれる

  関連事項:

  • ItemWriteListener.beforeWrite(Chunk)

• onWriteError

  public void onWriteError(ExceptionSE ex, Chunk<? extends S> items)

  インターフェースからコピーされた説明: ItemWriteListener

  書き込み中にエラーが発生した場合に呼び出されます。トランザクション内で呼び出されますが、トランザクションは通常ロールバックされます。このコールバックから、エラーの原因となった項目 (存在する場合) を特定する方法はありません。

  次で指定:

  インターフェース ItemWriteListener<T> の onWriteError 

  パラメーター:

  ex - ItemWriter からスロー

  items - 書こうとしました。

  関連事項:

  • ItemWriteListener.onWriteError(Exception, Chunk)

• onSkipInRead

  public void onSkipInRead(ThrowableSE t)

  インターフェースからコピーされた説明: SkipListener

  正当であり、その結果、再スローされない読み取りの失敗のコールバック。トランザクションがロールバックされ、アイテムが再読み込みされた場合、このコールバックは同じ原因で繰り返し発生します。これは、読み取り項目がバッファリングされていない場合にのみ発生します。

  次で指定:

  インターフェース SkipListener<T,S> の onSkipInRead 

  パラメーター:

  t - 失敗の原因

  関連事項:

  • CompositeSkipListener.onSkipInRead(java.lang.Throwable)

• onSkipInWrite

  public void onSkipInWrite(S item, ThrowableSE t)

  インターフェースからコピーされた説明: SkipListener

  この項目は、指定された例外で書き込み時に失敗し、スキップが要求されました。

  次で指定:

  インターフェース SkipListener<T,S> の onSkipInWrite 

  パラメーター:

  item - 失敗したアイテム

  t - 失敗の原因

  関連事項:

  • CompositeSkipListener.onSkipInWrite(java.lang.Object, java.lang.Throwable)

• onSkipInProcess

  public void onSkipInProcess(T item, ThrowableSE t)

  インターフェースからコピーされた説明: SkipListener

  このアイテムは、指定された例外で処理に失敗し、スキップが要求されました。

  次で指定:

  インターフェース SkipListener<T,S> の onSkipInProcess 

  パラメーター:

  item - 失敗したアイテム

  t - 失敗の原因

  関連事項:

  • CompositeSkipListener.onSkipInProcess(Object, Throwable)

• afterChunkError

  public void afterChunkError(ChunkContext context)

  インターフェースからコピーされた説明: ChunkListener

  チャンクがロールバック対象としてマークされた後のコールバック。トランザクションのロールバック後に呼び出されます。ロールバックが発生している間、トランザクションリソースがまだアクティブでアクセス可能である可能性があります。このため、このコールバック内のデータアクセスコードは、独自のトランザクションで実行することを宣言しない限り、元のトランザクションに「参加」します。そのため、here から呼び出されるすべてのトランザクション操作には PROPAGATION_REQUIRES_NEW を使用する必要があります。

  次で指定:

  インターフェース ChunkListener の afterChunkError 

  パラメーター:

  context - 基になるロールバックを引き起こした例外を含むチャンクコンテキスト。