jp.terasoluna.fw.batch.commonj.usequeue
クラス WorkManagerTaskWorkQueueFactory

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.commonj.usequeue.WorkManagerTaskWorkQueueFactory
すべての実装されたインタフェース:
WorkQueueFactory

public class WorkManagerTaskWorkQueueFactory
extends java.lang.Object
implements WorkQueueFactory

WorkQueueFactory インタフェースのCommonj用実装クラス。

このクラスでは、WorkManagerTaskWorkQueue のインスタンスを作成し、 作成したWorkManagerTaskWorkQueue のインスタンスをパラメータとして キュー処理プロセッサを起動したあとで、呼び出しもとに WorkManagerTaskWorkQueue のインスタンスを返す。


フィールドの概要
private  int multiplicity
          多重実行数。
private  int queueLength
          キューの長さ。
private  QueueProcessor queueProcessor
          キュー処理プロセッサ。
private  WorkerExecutorService workerExecutorService
          ワーカー実行サービス。
private  long workTimeout
          ジョブを開始するまでのタイムアウト(ミリ秒)。
 
コンストラクタの概要
WorkManagerTaskWorkQueueFactory()
           
 
メソッドの概要
 WorkQueue getWorkQueue(JobStatus jobStatus)
          ワークキューを取得する。
 void setMultiplicity(int multiplicity)
          多重実行数を設定する。
 void setQueueLength(int queueLength)
          キューの長さを設定する。
 void setQueueProcessor(QueueProcessor queueProcessor)
          キュー処理プロセッサを設定する。
 void setWorkerExecutorService(WorkerExecutorService workerExecutorService)
          ワーカー実行サービスを設定する。
 void setWorkTimeout(long workTimeout)
          ジョブを開始するまでのタイムアウト(ミリ秒)の設定。
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

queueLength

private int queueLength
キューの長さ。


queueProcessor

private QueueProcessor queueProcessor
キュー処理プロセッサ。


workerExecutorService

private WorkerExecutorService workerExecutorService
ワーカー実行サービス。


multiplicity

private int multiplicity
多重実行数。


workTimeout

private long workTimeout
ジョブを開始するまでのタイムアウト(ミリ秒)。

コンストラクタの詳細

WorkManagerTaskWorkQueueFactory

public WorkManagerTaskWorkQueueFactory()
メソッドの詳細

getWorkQueue

public WorkQueue getWorkQueue(JobStatus jobStatus)
ワークキューを取得する。

定義:
インタフェース WorkQueueFactory 内の getWorkQueue
パラメータ:
jobStatus - ジョブステータス
戻り値:
ワークキュー

setQueueLength

public void setQueueLength(int queueLength)
キューの長さを設定する。

パラメータ:
queueLength - キューの長さ

setQueueProcessor

public void setQueueProcessor(QueueProcessor queueProcessor)
キュー処理プロセッサを設定する。

パラメータ:
queueProcessor - キュー処理プロセッサ

setWorkerExecutorService

public void setWorkerExecutorService(WorkerExecutorService workerExecutorService)
ワーカー実行サービスを設定する。

パラメータ:
workerExecutorService - ワーカー実行サービス

setMultiplicity

public void setMultiplicity(int multiplicity)
多重実行数を設定する。

パラメータ:
multiplicity - 多重実行数

setWorkTimeout

public void setWorkTimeout(long workTimeout)
ジョブを開始するまでのタイムアウト(ミリ秒)の設定。

パラメータ:
workTimeout - タイムアウト(ミリ秒)