jp.terasoluna.fw.batch.restart
クラス RestartQueueProcessor

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.standard.QueueProcessor
      上位を拡張 jp.terasoluna.fw.batch.restart.RestartQueueProcessor

public class RestartQueueProcessor
extends QueueProcessor

リスタート時のキュー処理用クラス。

キューから要素を取り出し、取り出したそれぞれの要素をパラメータとしてワーカ ーを起動する。

キューの最後の要素であればリスタート用ワーカを起動する。 キューの最後の要素ではない場合は通常のワーカを起動する。


フィールドの概要
private  Workable<WorkUnit> normalWorker
          本処理&リスタート情報の登録・更新処理をするワーカー。
private  Workable<WorkUnit> restartWorker
          本処理&リスタート情報のクローズ処理をするワーカー。
 
コンストラクタの概要
RestartQueueProcessor()
           
 
メソッドの概要
 void process(WorkQueue workQueue, JobStatus jobStatus)
          キューの処理を行う。
 void setRestartWorker(Workable<WorkUnit> restartWorker)
          本処理&リスタート情報のクローズ処理をするワーカーを設定する。
 void setWorker(Workable<WorkUnit> worker)
          本処理&リスタート情報の登録・更新処理をするワーカーを設定する。
 
クラス jp.terasoluna.fw.batch.standard.QueueProcessor から継承されたメソッド
printEndLog, printStartLog, setName, setPostProcessor, setPreProcessor
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

normalWorker

private Workable<WorkUnit> normalWorker
本処理&リスタート情報の登録・更新処理をするワーカー。


restartWorker

private Workable<WorkUnit> restartWorker
本処理&リスタート情報のクローズ処理をするワーカー。

コンストラクタの詳細

RestartQueueProcessor

public RestartQueueProcessor()
メソッドの詳細

process

public void process(WorkQueue workQueue,
                    JobStatus jobStatus)
キューの処理を行う。

オーバーライド:
クラス QueueProcessor 内の process
パラメータ:
workQueue - キュー
jobStatus - ジョブステータス

setWorker

public void setWorker(Workable<WorkUnit> worker)
本処理&リスタート情報の登録・更新処理をするワーカーを設定する。

オーバーライド:
クラス QueueProcessor 内の setWorker
パラメータ:
worker - 本処理&リスタート情報の登録・更新処理をするワーカー

setRestartWorker

public void setRestartWorker(Workable<WorkUnit> restartWorker)
本処理&リスタート情報のクローズ処理をするワーカーを設定する。

パラメータ:
restartWorker - 本処理&リスタート情報のクローズ処理をするワーカーワーカー