jp.terasoluna.fw.batch.partition
クラス SequentialChildJobManager

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.core.JobManager
      上位を拡張 jp.terasoluna.fw.batch.partition.SequentialChildJobManager
すべての実装されたインタフェース:
Workable<WorkUnit>

public class SequentialChildJobManager
extends JobManager

分割ジョブにおいて、子ジョブを多重度1で逐次実行するためのジョブマネージ ャ。逐次実行している子ジョブのどれかが途中で終了した場合に、残りの子ジョブを 実行せずにジョブを停止する。

作業終了時に、このジョブマネージャのジョブステータスが終了状態であるときに 親ジョブのジョブステータスをこのジョブと同じジョブステータスに更新する。


フィールドの概要
private static Log log
          ログインスタンス。
private  java.lang.String name
          ジョブマネジャー名。
private  SupportProcessor postProcessor
          ジョブ後処理を行うサポートプロセッサ。
private  SupportProcessor preProcessor
          ジョブ前処理を行うサポートプロセッサ。
private  ThrowableHandler throwableHandler
          Throwableハンドラ。
private  WorkQueueFactory workQueueFactory
          作業キューのファクトリ。
 
コンストラクタの概要
SequentialChildJobManager()
           
 
メソッドの概要
protected  void finishWork(JobStatus parentJobStatus, JobStatus jobStatus)
          作業終了処理を行う。
 void setName(java.lang.String name)
          ジョブマネジャー名を設定する。
 void setPostProcessor(SupportProcessor postProcessor)
          ジョブ後処理を行うサポートプロセッサを設定する。
 void setPreProcessor(SupportProcessor preProcessor)
          ジョブ前処理を行うサポートプロセッサを設定する。
 void setThrowableHandler(ThrowableHandler throwableHandler)
          Throwableハンドラを設定する。
 void setWorkQueueFactory(WorkQueueFactory workQueueFactory)
          作業キューのファクトリを設定する。
 void work(WorkUnit workUnit, JobStatus jobStatus)
          作業を行う。
private  void writeEndLog(JobStatus jobStatus)
          JobManagerの終了ログを出力する。
private  void writeStartLog(JobStatus jobStatus)
          JobManagerの開始ログを出力する。
 
クラス jp.terasoluna.fw.batch.core.JobManager から継承されたメソッド
processCollect, setCollector, setCollectorResultHandler, setDefaultJobExceptionHandler, setExceptionHandlerMap
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

log

private static final Log log
ログインスタンス。


workQueueFactory

private WorkQueueFactory workQueueFactory
作業キューのファクトリ。


name

private java.lang.String name
ジョブマネジャー名。


throwableHandler

private ThrowableHandler throwableHandler
Throwableハンドラ。


preProcessor

private SupportProcessor preProcessor
ジョブ前処理を行うサポートプロセッサ。


postProcessor

private SupportProcessor postProcessor
ジョブ後処理を行うサポートプロセッサ。

コンストラクタの詳細

SequentialChildJobManager

public SequentialChildJobManager()
メソッドの詳細

work

public void work(WorkUnit workUnit,
                 JobStatus jobStatus)
作業を行う。
JobManagerクラスと違い例外が発生してもリターンコードをセットする。

定義:
インタフェース Workable<WorkUnit> 内の work
オーバーライド:
クラス JobManager 内の work
パラメータ:
workUnit - 作業単位
jobStatus - ジョブステータス

finishWork

protected void finishWork(JobStatus parentJobStatus,
                          JobStatus jobStatus)
作業終了処理を行う。

オーバーライド:
クラス JobManager 内の finishWork
パラメータ:
parentJobStatus - 起動元のジョブステータス
jobStatus - このジョブマネージャのジョブステータス

setWorkQueueFactory

public void setWorkQueueFactory(WorkQueueFactory workQueueFactory)
作業キューのファクトリを設定する。

オーバーライド:
クラス JobManager 内の setWorkQueueFactory
パラメータ:
workQueueFactory - 作業キューのファクトリ

setName

public void setName(java.lang.String name)
ジョブマネジャー名を設定する。

オーバーライド:
クラス JobManager 内の setName
パラメータ:
name - ジョブマネジャー名

setThrowableHandler

public void setThrowableHandler(ThrowableHandler throwableHandler)
Throwableハンドラを設定する。

オーバーライド:
クラス JobManager 内の setThrowableHandler
パラメータ:
throwableHandler - Throwableハンドラ

setPostProcessor

public void setPostProcessor(SupportProcessor postProcessor)
ジョブ後処理を行うサポートプロセッサを設定する。

オーバーライド:
クラス JobManager 内の setPostProcessor
パラメータ:
postProcessor - ジョブ後処理を行うサポートプロセッサ

setPreProcessor

public void setPreProcessor(SupportProcessor preProcessor)
ジョブ前処理を行うサポートプロセッサを設定する。

オーバーライド:
クラス JobManager 内の setPreProcessor
パラメータ:
preProcessor - ジョブ前処理を行うサポートプロセッサ

writeStartLog

private void writeStartLog(JobStatus jobStatus)
JobManagerの開始ログを出力する。

パラメータ:
jobStatus - ジョブステータス

writeEndLog

private void writeEndLog(JobStatus jobStatus)
JobManagerの終了ログを出力する。

パラメータ:
jobStatus - ジョブステータス