jp.terasoluna.fw.batch.springsupport.transaction
クラス TransactionalWorker

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.springsupport.transaction.TransactionalWorker
すべての実装されたインタフェース:
Workable<Chunk>

public class TransactionalWorker
extends java.lang.Object
implements Workable<Chunk>

トランザクション処理を行うワーカー実装クラス。

jobWorker 属性に設定されたワーカの呼び出しをトランザクション 制御を行いながら実行する。

セーブポイントを利用する場合には、本クラスでセーブポイントを使った トランザクション制御を行う。
ジョブワーカーの処理で例外が発生せず処理が終了した際に、 ジョブの処理状況が正常であればコミットを行い、それ以外の場合はロールバックを 行う。
ロールバックが前の処理で作成されたセーブポイントまで行われた場合は、 以前のセーブポイントまでの処理をコミットする。

また、キューの処理にて例外が発生せずに終了した後で、ジョブの処理状況が 中断終了中、もしくは強制終了中であった場合には、 処理状況を中断/強制終了に変更する。

トランザクション制御を行うため、ジョブステータスとして TransactionalJobStatusを使用する必要がある。


フィールドの概要
private  Workable<Chunk> jobWorker
          ジョブワーカー。
 
コンストラクタの概要
TransactionalWorker()
           
 
メソッドの概要
 void setJobWorker(Workable<Chunk> jobWorker)
          ジョブワーカーを設定する。
 void work(Chunk chunk, JobStatus jobStatus)
          ワーカーの処理を行う。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

jobWorker

private Workable<Chunk> jobWorker
ジョブワーカー。

コンストラクタの詳細

TransactionalWorker

public TransactionalWorker()
メソッドの詳細

work

public void work(Chunk chunk,
                 JobStatus jobStatus)
ワーカーの処理を行う。

定義:
インタフェース Workable<Chunk> 内の work
パラメータ:
chunk - チャンク
jobStatus - トランザクショナルジョブステータス

setJobWorker

public void setJobWorker(Workable<Chunk> jobWorker)
ジョブワーカーを設定する。

パラメータ:
jobWorker - ジョブワーカー