|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
java.lang.Objectjp.terasoluna.fw.batch.executor.AbstractBatchExecutor
jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor
public abstract class AbstractJobBatchExecutor
非同期バッチエグゼキュータ抽象クラス。
非同期ジョブ起動用のバッチエグゼキュータ。
BatchExecutor,
AbstractBatchExecutor,
AsyncBatchExecutor| フィールドの概要 | |
|---|---|
protected boolean |
changeStartStatus
開始時のステータス変更を行うかどうか |
protected static String |
DEFAULT_EXECUTOR_END_MONITORING_FILE
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)のデフォルト値 |
protected static long |
DEFAULT_EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
Executorのジョブ終了待ちチェック間隔(ミリ秒)のデフォルト値 |
protected static long |
DEFAULT_EXECUTOR_LOOP_INTERVAL_TIME
Executorの常駐モード時のジョブリスト取得間隔(ミリ秒)のデフォルト値 |
protected static long |
DEFAULT_EXECUTOR_QUEUE_CHECK_INTERVAL_TIME
Executorのスレッドキューサイズチェック間隔(ミリ秒)のデフォルト値 |
protected static boolean |
DEFAULT_JOB_AFTER_GC
ジョブ実行後にGCを行う(true/false)のデフォルト値 |
protected static long |
DEFAULT_JOB_INTERVAL_TIME
ジョブの実行間隔(ミリ秒)のデフォルト値 |
protected static String |
EXECUTOR_END_MONITORING_FILE
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)取得用キー. |
protected static String |
EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
Executorのジョブ終了待ちチェック間隔(ミリ秒)取得用キー. |
protected String |
executorEndMonitoringFile
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述) |
protected long |
executorJobTerminateWaitIntervalTime
Executorのジョブ終了待ちチェック間隔(ミリ秒) |
protected static String |
JOB_INTERVAL_TIME
ジョブの実行間隔(ミリ秒)取得用キー. |
protected long |
jobIntervalTime
ジョブの実行間隔(ミリ秒) |
| コンストラクタの概要 | |
|---|---|
protected |
AbstractJobBatchExecutor()
コンストラクタ |
| メソッドの概要 | |
|---|---|
protected boolean |
endBatchStatus(String jobSequenceId,
BLogicResult result,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新(ジョブ終了). |
BLogicResult |
executeBatch(String jobSequenceId)
バッチ実行. |
String |
getExecutorEndMonitoringFile()
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述) |
long |
getExecutorJobTerminateWaitIntervalTime()
Executorのジョブ終了待ちチェック間隔(ミリ秒) |
long |
getJobIntervalTime()
ジョブの実行間隔(ミリ秒) |
protected void |
initDefaultAppContext()
管理用に用いられるApplicationContextを初期化する. |
protected void |
initParameter()
初期化 |
protected void |
initSystemDatasourceDao()
システム共通で用いられるDAOをBean定義ファイルから取得する. |
protected String |
judgmentStatus(BatchJobData job,
String jobSequenceId,
String eventCode,
String blogicStatus)
ジョブステータスの更新判定メソッド イベントコードとジョブステータスを確認し、ジョブステータスの更新が必要か判定を行う。 |
void |
setChangeStartStatus(boolean changeStartStatus)
開始時のステータス変更を行うかどうか |
protected boolean |
startBatchStatus(String jobSequenceId,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新(ジョブ開始). |
protected boolean |
updateBatchStatus(String jobSequenceId,
String eventCode,
String blogicStatus,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新. |
| クラス java.lang.Object から継承されたメソッド |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| フィールドの詳細 |
|---|
protected static final String JOB_INTERVAL_TIME
protected static final String EXECUTOR_END_MONITORING_FILE
protected static final String EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
protected static final long DEFAULT_JOB_INTERVAL_TIME
protected static final boolean DEFAULT_JOB_AFTER_GC
protected static final long DEFAULT_EXECUTOR_LOOP_INTERVAL_TIME
protected static final String DEFAULT_EXECUTOR_END_MONITORING_FILE
protected static final long DEFAULT_EXECUTOR_QUEUE_CHECK_INTERVAL_TIME
protected static final long DEFAULT_EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
protected long jobIntervalTime
protected String executorEndMonitoringFile
protected long executorJobTerminateWaitIntervalTime
protected boolean changeStartStatus
| コンストラクタの詳細 |
|---|
protected AbstractJobBatchExecutor()
| メソッドの詳細 |
|---|
protected void initDefaultAppContext()
AbstractBatchExecutor の記述:
AbstractBatchExecutor 内の initDefaultAppContextprotected void initSystemDatasourceDao()
AbstractBatchExecutor の記述:
AbstractBatchExecutor 内の initSystemDatasourceDaoprotected void initParameter()
public BLogicResult executeBatch(String jobSequenceId)
jobSequenceId - ジョブシーケンスコード
protected boolean startBatchStatus(String jobSequenceId,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
jobSequenceId - 更新対象のジョブシーケンスコードqueryDAO - QueryDAOupdateDAO - UpdateDAOtransactionManager - TransactionManager
protected boolean endBatchStatus(String jobSequenceId,
BLogicResult result,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
jobSequenceId - 更新対象のジョブシーケンスコードresult - ステータスqueryDAO - QueryDAOupdateDAO - UpdateDAOtransactionManager - TransactionManager
protected boolean updateBatchStatus(String jobSequenceId,
String eventCode,
String blogicStatus,
jp.terasoluna.fw.dao.QueryDAO queryDAO,
jp.terasoluna.fw.dao.UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ステータス判定マップにしたがって、ジョブのステータスを反映
jobSequenceId - 更新対象のジョブシーケンスコードeventCode - イベントコードblogicStatus - blogicの戻り値queryDAO - QueryDAOupdateDAO - UpdateDAOtransactionManager - TransactionManager
protected String judgmentStatus(BatchJobData job,
String jobSequenceId,
String eventCode,
String blogicStatus)
job - ジョブレコードjobSequenceId - 更新対象のジョブシーケンスコードeventCode - イベントコードblogicStatus - blogicの戻り値
public long getJobIntervalTime()
public String getExecutorEndMonitoringFile()
public long getExecutorJobTerminateWaitIntervalTime()
public void setChangeStartStatus(boolean changeStartStatus)
changeStartStatus - the changeStartStatus to set
|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||