|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
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 final 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 - ジョブステータス
|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||