jp.terasoluna.fw.batch.standard
クラス QueueProcessor

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.standard.QueueProcessor
直系の既知のサブクラス:
RestartQueueProcessor, TransactionalQueueProcessor

public class QueueProcessor
extends java.lang.Object

キュー処理用クラス。

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

中断終了時は、ワーカーで適切な後続処理を行う必要があるため、このクラスでは何もしない。

キューの要素の処理をはじめる前には、設定された前処理プロセッサを起動する。 前処理プロセッサを起動する際には、キューの先頭要素の JobContext が使用される。

すべてのキューの要素の処理が終わった後に、設定された後処理プロセッサを起動 する。後処理プロセッサを起動する際には、キューの最終要素の JobContext が使用される。

キューに要素が一個も存在しなかった場合には、前処理プロセッサ、後処理プロセ ッサの両方とも起動されない。


フィールドの概要
private static Log log
          ログインスタンス。
private  java.lang.String name
          キュープロセッサの名称。
private  SupportProcessor postProcessor
          後処理プロセッサ。
private  SupportProcessor preProcessor
          前処理プロセッサ。
private  Workable<WorkUnit> worker
          ワーカー。
 
コンストラクタの概要
QueueProcessor()
           
 
メソッドの概要
protected  void printEndLog(java.lang.String message, JobStatus jobStatus)
          QueueProcessorの終了ログを出力する。
protected  void printStartLog(java.lang.String message, JobStatus jobStatus)
          QueueProcessorの開始ログを出力する。
 void process(WorkQueue workQueue, JobStatus jobStatus)
          キューの処理を行う。
 void setName(java.lang.String name)
          名称を設定する。
 void setPostProcessor(SupportProcessor postProcessor)
          後処理プロセッサを設定する。
 void setPreProcessor(SupportProcessor preProcessor)
          前処理プロセッサを設定する。
 void setWorker(Workable<WorkUnit> worker)
          ワーカーを設定する。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

log

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


worker

private Workable<WorkUnit> worker
ワーカー。


name

private java.lang.String name
キュープロセッサの名称。


preProcessor

private SupportProcessor preProcessor
前処理プロセッサ。キューの要素を処理する前に起動される。


postProcessor

private SupportProcessor postProcessor
後処理プロセッサ。キューの要素をすべて処理した後で起動される。

コンストラクタの詳細

QueueProcessor

public QueueProcessor()
メソッドの詳細

process

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

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

setWorker

public void setWorker(Workable<WorkUnit> worker)
ワーカーを設定する。

パラメータ:
worker - ワーカー

setName

public void setName(java.lang.String name)
名称を設定する。

パラメータ:
name - 名称

setPostProcessor

public void setPostProcessor(SupportProcessor postProcessor)
後処理プロセッサを設定する。

パラメータ:
postProcessor - 後処理プロセッサ

setPreProcessor

public void setPreProcessor(SupportProcessor preProcessor)
前処理プロセッサを設定する。

パラメータ:
preProcessor - 前処理プロセッサ

printStartLog

protected void printStartLog(java.lang.String message,
                             JobStatus jobStatus)
QueueProcessorの開始ログを出力する。

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

printEndLog

protected void printEndLog(java.lang.String message,
                           JobStatus jobStatus)
QueueProcessorの終了ログを出力する。

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