public abstract class AbstractJobBatchExecutor extends AbstractBatchExecutor
修飾子とタイプ | フィールドと説明 |
---|---|
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
ジョブの実行間隔(ミリ秒)
|
APPLICATION_CONTEXT, ARGUMENT_COUNT, BEAN_DEFINITION_ADMIN_CLASSPATH_KEY, BEAN_DEFINITION_BUSINESS_CLASSPATH_KEY, BEAN_DEFINITION_DATASOURCE, BEAN_DEFINITION_DEFAULT, BEAN_MESSAGE_ACCESSOR_DEFAULT, cl, DEFAULT_BLOGIC_BEAN_NAME_SUFFIX, DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME, DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME_SUFFIX, defaultApplicationContext, ENABLE_JOBCOMPONENT_ANNOTATION, enableJobComponentAnnotation, ENV_BLOGIC_APP_STATUS, ENV_CUR_APP_STATUS, ENV_JOB_APP_CD, ENV_JOB_ARG_MAX, ENV_JOB_ARG_NM, ENV_JOB_ARG_NM1, ENV_JOB_ARG_NM10, ENV_JOB_ARG_NM11, ENV_JOB_ARG_NM12, ENV_JOB_ARG_NM13, ENV_JOB_ARG_NM14, ENV_JOB_ARG_NM15, ENV_JOB_ARG_NM16, ENV_JOB_ARG_NM17, ENV_JOB_ARG_NM18, ENV_JOB_ARG_NM19, ENV_JOB_ARG_NM2, ENV_JOB_ARG_NM20, ENV_JOB_ARG_NM3, ENV_JOB_ARG_NM4, ENV_JOB_ARG_NM5, ENV_JOB_ARG_NM6, ENV_JOB_ARG_NM7, ENV_JOB_ARG_NM8, ENV_JOB_ARG_NM9, ENV_JOB_BEAN_DEFINITION_PATH, ENV_JOB_SEQ_ID, FIELD_JOB_ARG, PROPERTY_BEAN_FILENAME_SUFFIX, REPLACE_STRING_JOB_APP_CD, REPLACE_STRING_JOB_APP_CD_LOWER, REPLACE_STRING_JOB_APP_CD_UPPER, REPLACE_STRING_JOB_ARG, REPLACE_STRING_JOB_ARG_MAX, REPLACE_STRING_PREFIX, REPLACE_STRING_SUFFIX, sysQueryDAO, SYSTEM_DATASOURCE_QUERY_DAO, SYSTEM_DATASOURCE_TRANSACTION_MANAGER, SYSTEM_DATASOURCE_UPDATE_DAO, sysTransactionManager, sysUpdateDAO
修飾子 | コンストラクタと説明 |
---|---|
protected |
AbstractJobBatchExecutor()
コンストラクタ
|
修飾子とタイプ | メソッドと説明 |
---|---|
protected boolean |
endBatchStatus(String jobSequenceId,
BLogicResult result,
QueryDAO queryDAO,
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,
QueryDAO queryDAO,
UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新(ジョブ開始).
|
protected boolean |
updateBatchStatus(String jobSequenceId,
String eventCode,
String blogicStatus,
QueryDAO queryDAO,
UpdateDAO updateDAO,
org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新.
|
argumentCopy, closeApplicationContext, convertBLogicParam, executeBatch, executeBatchClass, getApplicationContext, getBeanFileName, getBlogicBeanName, getDataSourceBeanFileName, getDefaultApplicationContext, getDefaultBeanFileName, getDefaultExceptionHandlerBeanName, getExceptionHandlerBeanName, getMethod, getSysQueryDAO, getSysTransactionManager, getSysUpdateDAO, getThreadMessage, init, initDefaultErrorMessage, initJobAppContext, replaceString, setMethod
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 void initDefaultAppContext()
AbstractBatchExecutor
initDefaultAppContext
クラス内 AbstractBatchExecutor
protected void initSystemDatasourceDao()
AbstractBatchExecutor
initSystemDatasourceDao
クラス内 AbstractBatchExecutor
protected void initParameter()
public BLogicResult executeBatch(String jobSequenceId)
jobSequenceId
- ジョブシーケンスコードprotected boolean startBatchStatus(String jobSequenceId, QueryDAO queryDAO, UpdateDAO updateDAO, org.springframework.transaction.PlatformTransactionManager transactionManager)
jobSequenceId
- 更新対象のジョブシーケンスコードqueryDAO
- QueryDAOupdateDAO
- UpdateDAOtransactionManager
- TransactionManagerprotected boolean endBatchStatus(String jobSequenceId, BLogicResult result, QueryDAO queryDAO, UpdateDAO updateDAO, org.springframework.transaction.PlatformTransactionManager transactionManager)
jobSequenceId
- 更新対象のジョブシーケンスコードresult
- ステータスqueryDAO
- QueryDAOupdateDAO
- UpdateDAOtransactionManager
- TransactionManagerprotected boolean updateBatchStatus(String jobSequenceId, String eventCode, String blogicStatus, QueryDAO queryDAO, UpdateDAO updateDAO, org.springframework.transaction.PlatformTransactionManager transactionManager)
ステータス判定マップにしたがって、ジョブのステータスを反映
jobSequenceId
- 更新対象のジョブシーケンスコードeventCode
- イベントコードblogicStatus
- blogicの戻り値queryDAO
- QueryDAOupdateDAO
- UpdateDAOtransactionManager
- TransactionManagerprotected 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 setCopyright © 2014 NTT DATA Corporation.