| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
java.lang.Objectjp.terasoluna.fw.batch.standard.QueueProcessor
public class QueueProcessor
キュー処理用クラス。
キューから要素を取り出し、取り出したそれぞれの要素をパラメータとしてワーカ ーを起動する。
中断終了時は、ワーカーで適切な後続処理を行う必要があるため、このクラスでは何もしない。キューの要素の処理をはじめる前には、設定された前処理プロセッサを起動する。
 前処理プロセッサを起動する際には、キューの先頭要素の JobContext 
 が使用される。
すべてのキューの要素の処理が終わった後に、設定された後処理プロセッサを起動
 する。後処理プロセッサを起動する際には、キューの最終要素の JobContext
  が使用される。
キューに要素が一個も存在しなかった場合には、前処理プロセッサ、後処理プロセ ッサの両方とも起動されない。
| フィールドの概要 | |
|---|---|
| private static org.apache.commons.logging.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 | 
| フィールドの詳細 | 
|---|
private static org.apache.commons.logging.Log log
private Workable<WorkUnit> worker
private java.lang.String name
private SupportProcessor preProcessor
private SupportProcessor postProcessor
| コンストラクタの詳細 | 
|---|
public QueueProcessor()
| メソッドの詳細 | 
|---|
public void process(WorkQueue workQueue,
                    JobStatus jobStatus)
workQueue - キューjobStatus - ジョブステータスpublic void setWorker(Workable<WorkUnit> worker)
worker - ワーカーpublic void setName(java.lang.String name)
name - 名称public void setPostProcessor(SupportProcessor postProcessor)
postProcessor - 後処理プロセッサpublic void setPreProcessor(SupportProcessor preProcessor)
preProcessor - 前処理プロセッサ
protected void printStartLog(java.lang.String message,
                             JobStatus jobStatus)
message - メッセージjobStatus - ジョブステータス
protected void printEndLog(java.lang.String message,
                           JobStatus jobStatus)
message - メッセージjobStatus - ジョブステータス| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||