jp.terasoluna.fw.batch.init
クラス JobRequestInfoCollector

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.core.AbstractCollector
      上位を拡張 jp.terasoluna.fw.batch.init.JobRequestInfoCollector
すべての実装されたインタフェース:
Collector

public class JobRequestInfoCollector
extends AbstractCollector

非同期ジョブ起動時のジョブ依頼情報取得用クラス。


フィールドの概要
private  long intervalSeconds
          ジョブ管理テーブルの監視周期(秒)。
protected  java.lang.String jobBeanPath
          実行ジョブ定義ファイルパス。
protected  JobControlTableHandler jobControlTableHandler
          ジョブ管理テーブルハンドラクラスのインスタンス。
private static Log log
          ログインスタンス。
private  int refreshCount
          リフレッシュカウント。
 
コンストラクタの概要
JobRequestInfoCollector()
           
 
メソッドの概要
protected  CollectorResult doCollect(JobContext jobContext, CollectedDataHandler collectedDataHandler, JobStatus jobStatus)
          ジョブ依頼情報取得、監視処理の実行。
protected  JobInfo getJobMessageInfo(int selectCount, JobInfo jobInfo)
          処理対象データの取得
protected  void overrideDescriptionPath(JobInfo jobInfo)
          ジョブBean定義パスの上書き
 void setIntervalSeconds(long intervalSeconds)
          監視周期を設定する。
 void setJobBeanPath(java.lang.String jobBeanPath)
          実行ジョブ定義ファイルパス。
 void setJobControlTableHandler(JobControlTableHandler jobControlTableHandler)
          ジョブ管理テーブルハンドラクラスのインスタンスを設定する。
 void setRefreshCount(int refreshCount)
          リフレッシュカウントを設定する。
protected  int updateJobStart(JobInfo jobInfo)
          キューに入れる前にジョブ起動状況を開始に更新する
 
クラス jp.terasoluna.fw.batch.core.AbstractCollector から継承されたメソッド
collect, setCollectedDataHandlerFactory
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

log

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


jobControlTableHandler

protected JobControlTableHandler jobControlTableHandler
ジョブ管理テーブルハンドラクラスのインスタンス。


intervalSeconds

private long intervalSeconds
ジョブ管理テーブルの監視周期(秒)。


refreshCount

private int refreshCount
リフレッシュカウント。


jobBeanPath

protected java.lang.String jobBeanPath
実行ジョブ定義ファイルパス。

コンストラクタの詳細

JobRequestInfoCollector

public JobRequestInfoCollector()
メソッドの詳細

doCollect

protected CollectorResult doCollect(JobContext jobContext,
                                    CollectedDataHandler collectedDataHandler,
                                    JobStatus jobStatus)
ジョブ依頼情報取得、監視処理の実行。
ジョブ監視を行い取得対象のジョブが無い場合はデーモン起動用ジョブBean定義 の監視周期時間を待機した後、再取得処理を行う。
ジョブ依頼情報の取得は直前取得したジョブリクエスト番号より大きいものを取 得するがこの条件はデーモン起動用ジョブBean定義のリフレッシュ番号の回数毎 にリフレッシュされる。

定義:
クラス AbstractCollector 内の doCollect
パラメータ:
jobContext - ジョブコンテキスト
collectedDataHandler - ワーカキュー
jobStatus - 処理状況
戻り値:
コレクタ処理結果

updateJobStart

protected int updateJobStart(JobInfo jobInfo)
キューに入れる前にジョブ起動状況を開始に更新する

パラメータ:
jobInfo - 対象ジョブ情報
戻り値:
更新行数

getJobMessageInfo

protected JobInfo getJobMessageInfo(int selectCount,
                                    JobInfo jobInfo)
処理対象データの取得

パラメータ:
selectCount - 取得データ数
jobInfo - 対象ジョブ情報
戻り値:
対象ジョブ情報

overrideDescriptionPath

protected void overrideDescriptionPath(JobInfo jobInfo)
ジョブBean定義パスの上書き

パラメータ:
jobInfo - 対象ジョブ情報

setJobControlTableHandler

public void setJobControlTableHandler(JobControlTableHandler jobControlTableHandler)
ジョブ管理テーブルハンドラクラスのインスタンスを設定する。

パラメータ:
jobControlTableHandler - ジョブ管理テーブルハンドラクラスのインスタ ンス

setIntervalSeconds

public void setIntervalSeconds(long intervalSeconds)
監視周期を設定する。

パラメータ:
intervalSeconds - 監視周期(秒)

setRefreshCount

public void setRefreshCount(int refreshCount)
リフレッシュカウントを設定する。

パラメータ:
refreshCount - リフレッシュカウント。

setJobBeanPath

public void setJobBeanPath(java.lang.String jobBeanPath)
実行ジョブ定義ファイルパス。

パラメータ:
jobBeanPath - 実行ジョブ定義ファイルパス