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