|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
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
内の initDefaultAppContext
protected void initSystemDatasourceDao()
AbstractBatchExecutor
の記述:
AbstractBatchExecutor
内の initSystemDatasourceDao
protected 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
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |