jp.terasoluna.fw.batch.executor
クラス AbstractJobBatchExecutor

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.executor.AbstractBatchExecutor
      上位を拡張 jp.terasoluna.fw.batch.executor.AbstractJobBatchExecutor
すべての実装されたインタフェース:
BatchExecutor
直系の既知のサブクラス:
AsyncBatchExecutor, BatchServantImpl

public abstract class AbstractJobBatchExecutor
extends AbstractBatchExecutor

非同期バッチエグゼキュータ抽象クラス。

非同期ジョブ起動用のバッチエグゼキュータ。

関連項目:
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
          ジョブの実行間隔(ミリ秒)
 
クラス jp.terasoluna.fw.batch.executor.AbstractBatchExecutor から継承されたフィールド
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, 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, PROPERTY_BEAN_FILENAME_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, 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)
          ジョブステータス更新.
 
クラス jp.terasoluna.fw.batch.executor.AbstractBatchExecutor から継承されたメソッド
argumentCopy, closeApplicationContext, convertBLogicParam, executeBatch, executeBatchClass, getApplicationContext, getBeanFileName, getBlogicBeanName, getDataSourceBeanFileName, getDefaultApplicationContext, getDefaultBeanFileName, getDefaultExceptionHandlerBeanName, getExceptionHandlerBeanName, getMethod, getSysQueryDAO, getSysTransactionManager, getSysUpdateDAO, init, initDefaultErrorMessage, initJobAppContext, setMethod
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

JOB_INTERVAL_TIME

protected static final String JOB_INTERVAL_TIME
ジョブの実行間隔(ミリ秒)取得用キー.

関連項目:
定数フィールド値

EXECUTOR_END_MONITORING_FILE

protected static final String EXECUTOR_END_MONITORING_FILE
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)取得用キー.

関連項目:
定数フィールド値

EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME

protected static final String EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
Executorのジョブ終了待ちチェック間隔(ミリ秒)取得用キー.

関連項目:
定数フィールド値

DEFAULT_JOB_INTERVAL_TIME

protected static final long DEFAULT_JOB_INTERVAL_TIME
ジョブの実行間隔(ミリ秒)のデフォルト値

関連項目:
定数フィールド値

DEFAULT_JOB_AFTER_GC

protected static final boolean DEFAULT_JOB_AFTER_GC
ジョブ実行後にGCを行う(true/false)のデフォルト値

関連項目:
定数フィールド値

DEFAULT_EXECUTOR_LOOP_INTERVAL_TIME

protected static final long DEFAULT_EXECUTOR_LOOP_INTERVAL_TIME
Executorの常駐モード時のジョブリスト取得間隔(ミリ秒)のデフォルト値

関連項目:
定数フィールド値

DEFAULT_EXECUTOR_END_MONITORING_FILE

protected static final String DEFAULT_EXECUTOR_END_MONITORING_FILE
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)のデフォルト値


DEFAULT_EXECUTOR_QUEUE_CHECK_INTERVAL_TIME

protected static final long DEFAULT_EXECUTOR_QUEUE_CHECK_INTERVAL_TIME
Executorのスレッドキューサイズチェック間隔(ミリ秒)のデフォルト値

関連項目:
定数フィールド値

DEFAULT_EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME

protected static final long DEFAULT_EXECUTOR_JOB_TERMINATE_WAIT_INTERVAL_TIME
Executorのジョブ終了待ちチェック間隔(ミリ秒)のデフォルト値

関連項目:
定数フィールド値

jobIntervalTime

protected long jobIntervalTime
ジョブの実行間隔(ミリ秒)


executorEndMonitoringFile

protected String executorEndMonitoringFile
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)


executorJobTerminateWaitIntervalTime

protected long executorJobTerminateWaitIntervalTime
Executorのジョブ終了待ちチェック間隔(ミリ秒)


changeStartStatus

protected boolean changeStartStatus
開始時のステータス変更を行うかどうか

コンストラクタの詳細

AbstractJobBatchExecutor

protected AbstractJobBatchExecutor()
コンストラクタ

メソッドの詳細

initDefaultAppContext

protected void initDefaultAppContext()
クラス AbstractBatchExecutor の記述:
管理用に用いられるApplicationContextを初期化する.

オーバーライド:
クラス AbstractBatchExecutor 内の initDefaultAppContext

initSystemDatasourceDao

protected void initSystemDatasourceDao()
クラス AbstractBatchExecutor の記述:
システム共通で用いられるDAOをBean定義ファイルから取得する.

オーバーライド:
クラス AbstractBatchExecutor 内の initSystemDatasourceDao

initParameter

protected void initParameter()
初期化


executeBatch

public BLogicResult executeBatch(String jobSequenceId)
バッチ実行.

パラメータ:
jobSequenceId - ジョブシーケンスコード
戻り値:
ビジネスロジック実行結果

startBatchStatus

protected boolean startBatchStatus(String jobSequenceId,
                                   jp.terasoluna.fw.dao.QueryDAO queryDAO,
                                   jp.terasoluna.fw.dao.UpdateDAO updateDAO,
                                   org.springframework.transaction.PlatformTransactionManager transactionManager)
ジョブステータス更新(ジョブ開始).

パラメータ:
jobSequenceId - 更新対象のジョブシーケンスコード
queryDAO - QueryDAO
updateDAO - UpdateDAO
transactionManager - TransactionManager
戻り値:
ジョブステータス更新が成功したらtrue

endBatchStatus

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 - QueryDAO
updateDAO - UpdateDAO
transactionManager - TransactionManager
戻り値:
ステータス更新が成功したらtrue

updateBatchStatus

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 - QueryDAO
updateDAO - UpdateDAO
transactionManager - TransactionManager
戻り値:
ステータス更新が成功したらtrue

judgmentStatus

protected String judgmentStatus(BatchJobData job,
                                String jobSequenceId,
                                String eventCode,
                                String blogicStatus)
ジョブステータスの更新判定メソッド
イベントコードとジョブステータスを確認し、ジョブステータスの更新が必要か判定を行う。
更新が必要ない場合はInfoログを出力し、nullを返却する。

パラメータ:
job - ジョブレコード
jobSequenceId - 更新対象のジョブシーケンスコード
eventCode - イベントコード
blogicStatus - blogicの戻り値
戻り値:

getJobIntervalTime

public long getJobIntervalTime()
ジョブの実行間隔(ミリ秒)

戻り値:
the jobIntervalTime

getExecutorEndMonitoringFile

public String getExecutorEndMonitoringFile()
Executorの常駐モード時の終了フラグ監視ファイル(フルパスで記述)

戻り値:
the executorEndMonitoringFile

getExecutorJobTerminateWaitIntervalTime

public long getExecutorJobTerminateWaitIntervalTime()
Executorのジョブ終了待ちチェック間隔(ミリ秒)

戻り値:
the executorJobTerminateWaitIntervalTime

setChangeStartStatus

public void setChangeStartStatus(boolean changeStartStatus)
開始時のステータス変更を行うかどうか

パラメータ:
changeStartStatus - the changeStartStatus to set


Copyright © 2011. All Rights Reserved.