| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
java.lang.Objectjp.terasoluna.fw.batch.springsupport.init.JobExecutor
public class JobExecutor
ジョブ起動用メインクラス。
 ジョブ起動前のJobBeanFactoryの生成や破棄処理を行う。
 生成されたJobBeanFactoryはキャッシュされ同じジョブが実行された
 場合は キャッシュしたJobBeanFactoryを返す。
| フィールドの概要 | |
|---|---|
| private  JobContext.START_TYPE | async非同期起動有無フラグ。 | 
| protected static java.lang.String | DATA_ACCESS_CONTEXT_DEFINITION_NAMEデータアクセス用Bean定義ファイル名。 | 
| private static java.lang.String | ENDFILECHECKER_NAMEジョブ終了監視用Bean名。 | 
| private static java.lang.String | EXITCODE_MAPデフォルト終了コード。 | 
| private static java.lang.String | FRAMEWORK_BEAN_DEFINITION_NAMEフレームワークBean定義ファイル名。 | 
| private  org.springframework.context.ConfigurableApplicationContext | frameworkFactoryフレームワークBeanFactory。 | 
| private static java.lang.String | JOBCONTEXT_NAMEジョブコンテキストBean名。 | 
| private  java.util.Map<java.lang.String,java.lang.String> | jobExitCodeMapデフォルトのジョブ終了コードのマップ。 | 
| private  java.util.Map<java.lang.String,org.springframework.context.ConfigurableApplicationContext> | jobFactoryMapジョブBeanFactoryのキャッシュ用Map。 | 
| private static java.lang.String | JOBMANAGER_NAMEジョブマネージャBean名。 | 
| private  java.lang.String | jobParametersSplitStrジョブパラメータの区切り文字。 | 
| protected static java.lang.String | JOBSTATUS_NAMEジョブ状況用Bean名。 | 
| protected static java.lang.String | JOBSTATUS_SUMMARIZER処理状態のサマライザ。 | 
| private static org.apache.commons.logging.Log | logログインスタンス。 | 
| protected static java.lang.String | MONITORABLE_JOBSTATUS_NAMEモニター用ジョブ状況用Bean名。 | 
| private  SupportProcessor | postJobProcessorジョブ後処理用インスタンス。 | 
| private  SupportProcessor | preJobProcessorジョブ前処理用インスタンス。 | 
| private static java.lang.String | THREAD_POOL_DEFINITION_NAMEスレッドプール用Bean定義ファイル名。 | 
| private  ThrowableHandler | throwableHandlerThrowableハンドラ。 | 
| private static java.lang.String | THROWABLEHANDLER_NAMEThrowableハンドラ用Bean名。 | 
| protected static java.lang.String | USE_MONITORABLEジョブ終了監視用Bean名。 | 
| protected static java.lang.String | USECACHE_NAMEキャッシュ有無用Bean名。 | 
| protected static java.lang.String | VALIDATE_DEFINITION_NAMEスレッドプール用Bean定義ファイル名。 | 
| コンストラクタの概要 | |
|---|---|
| protected  | JobExecutor()コンストラクタ。 | 
| protected  | JobExecutor(java.lang.String[] beanFileName)コンストラクタ。 | 
| メソッドの概要 | |
|---|---|
| private  void | checkJobInfo(JobInfo jobInfo)英数字文字例であるかをチェックする。 | 
|  void | destroy()作成した BeanFactoryの破棄処理を行う。 | 
| protected  JobStatus | execute(JobInfo jobInfo)ジョブを実行する。 | 
| protected  org.springframework.context.ConfigurableApplicationContext | getFrameworkFactory()フレームワークBeanFactoryの取得 | 
| protected  org.springframework.context.ConfigurableApplicationContext | getJobBeanFactory(JobInfo jobInfo)ジョブ毎の BeanFactoryを取得するメソッド。 | 
| protected  JobContext | getJobContext(org.springframework.context.ConfigurableApplicationContext jobFactory,
              JobInfo jobInfo)ジョブコンテキストの取得。 | 
| protected  Workable<WorkUnit> | getJobManager(org.springframework.context.ConfigurableApplicationContext jobFactory)ジョブマネージャを取得する。 | 
| protected  JobStatus | getJobStatus(org.springframework.context.ConfigurableApplicationContext jobFactory,
             JobInfo jobInfo)ジョブ処理状態格納用 JobStatusを取得する。 | 
| protected  WorkUnit | getWorkUnit(JobContext jobContext)WorkUnitを生成し、ジョブコンテキストを設定する。 | 
| private  void | initDefaultJobExitCodeMap()ジョブ終了コードのマップを初期化する。 | 
| protected  void | initEndFileChecker(JobStatus jobStatus,
                   JobContext jobContext)終了ファイル監視スレッドの初期化を行う。 | 
| protected  boolean | isAsync()非同期ジョブ起動であるかを評価する。 | 
| protected  void | printEndLog(JobStatus jobStatus)ジョブの開始ログを出力する。 | 
| protected  void | printStartLog(JobInfo jobInfo)ジョブの開始ログを出力する。 | 
| protected  void | removeJobStatusFromEndFileChecker(JobStatus jobStatus,
                                  JobContext jobContext)終了ファイル監視スレッドに登録されたジョブの処理状態を削除する。 | 
|  void | setAsync(boolean async)非同期起動有無フラグを設定する。 | 
| protected  void | setDefaultJobExitCode(JobStatus jobStatus)ジョブ終了コードを設定する。 | 
|  void | setJobParametersSplitStr(java.lang.String jobParametersSplitStr)ジョブパラメータの区切り文字を設定する。 | 
|  void | setPostJobProcessor(SupportProcessor postJobProcessor)ジョブ起動前処理を設定する。 | 
|  void | setPreJobProcessor(SupportProcessor preJobProcessor)ジョブ起動後処理を設定する。 | 
|  void | setThrowableHandler(ThrowableHandler throwableHandler)Throwableハンドラを設定する。 | 
|  void | work(AbstractJobControlInfo jobInfo,
     JobStatus jobStatus)非同期型ジョブ起動時のワーカメソッド。 | 
| クラス java.lang.Object から継承されたメソッド | 
|---|
| clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait | 
| フィールドの詳細 | 
|---|
private static org.apache.commons.logging.Log log
private static final java.lang.String FRAMEWORK_BEAN_DEFINITION_NAME
protected static final java.lang.String DATA_ACCESS_CONTEXT_DEFINITION_NAME
private static final java.lang.String THREAD_POOL_DEFINITION_NAME
protected static final java.lang.String VALIDATE_DEFINITION_NAME
protected static final java.lang.String USECACHE_NAME
private static final java.lang.String JOBCONTEXT_NAME
private static final java.lang.String JOBMANAGER_NAME
protected static final java.lang.String JOBSTATUS_NAME
protected static final java.lang.String MONITORABLE_JOBSTATUS_NAME
private static final java.lang.String ENDFILECHECKER_NAME
protected static final java.lang.String USE_MONITORABLE
protected static final java.lang.String JOBSTATUS_SUMMARIZER
private static final java.lang.String EXITCODE_MAP
private static final java.lang.String THROWABLEHANDLER_NAME
private org.springframework.context.ConfigurableApplicationContext frameworkFactory
private java.util.Map<java.lang.String,org.springframework.context.ConfigurableApplicationContext> jobFactoryMap
private JobContext.START_TYPE async
private SupportProcessor preJobProcessor
private SupportProcessor postJobProcessor
private java.util.Map<java.lang.String,java.lang.String> jobExitCodeMap
private java.lang.String jobParametersSplitStr
private ThrowableHandler throwableHandler
| コンストラクタの詳細 | 
|---|
protected JobExecutor()
FrameworkFactory 初期化処理を行う。
protected JobExecutor(java.lang.String[] beanFileName)
FrameworkFactory 初期化処理を行う。
beanFileName - Bean定義ファイル| メソッドの詳細 | 
|---|
protected org.springframework.context.ConfigurableApplicationContext getJobBeanFactory(JobInfo jobInfo)
BeanFactoryを取得するメソッド。BeanFactoryはキャッシュし再利用される。
jobInfo - ジョブ依頼情報
BeanFactoryprotected boolean isAsync()
trueを返す。protected Workable<WorkUnit> getJobManager(org.springframework.context.ConfigurableApplicationContext jobFactory)
jobFactory - ジョブ毎のBeanFactory
protected JobContext getJobContext(org.springframework.context.ConfigurableApplicationContext jobFactory,
                                   JobInfo jobInfo)
jobFactory - ジョブ毎のBeanFactoryjobInfo - ジョブ依頼情報
protected JobStatus getJobStatus(org.springframework.context.ConfigurableApplicationContext jobFactory,
                                 JobInfo jobInfo)
JobStatusを取得する。JobStatusを取得し、初期値を設定する。
jobFactory - ジョブ毎のBeanFactoryjobInfo - ジョブ依頼情報
JobStatusprotected WorkUnit getWorkUnit(JobContext jobContext)
WorkUnitを生成し、ジョブコンテキストを設定する。
jobContext - ジョブコンテキスト
WorkUnit
protected void initEndFileChecker(JobStatus jobStatus,
                                  JobContext jobContext)
jobStatus - ジョブの処理状態jobContext - ジョブコンテキスト
protected void removeJobStatusFromEndFileChecker(JobStatus jobStatus,
                                                 JobContext jobContext)
jobStatus - ジョブの処理状態jobContext - ジョブコンテキストprotected JobStatus execute(JobInfo jobInfo)
jobInfo - ジョブ依頼情報
protected void printStartLog(JobInfo jobInfo)
jobInfo - ジョブ依頼情報protected void printEndLog(JobStatus jobStatus)
jobStatus - ジョブの処理状態private void checkJobInfo(JobInfo jobInfo)
jobInfo - チェック対象の文字例protected void setDefaultJobExitCode(JobStatus jobStatus)
jobStatus - 処理対象の処理状況private void initDefaultJobExitCodeMap()
public void work(AbstractJobControlInfo jobInfo,
                 JobStatus jobStatus)
Workable<AbstractJobControlInfo> 内の workjobInfo - ジョブ依頼情報jobStatus - ジョブステータスpublic void destroy()
BeanFactoryの破棄処理を行う。JobBeanFactory及ぶFrameworkBeanFactory
 を破棄する。
org.springframework.beans.factory.DisposableBean 内の destroypublic void setAsync(boolean async)
async - 非同期起動有無フラグpublic void setPreJobProcessor(SupportProcessor preJobProcessor)
preJobProcessor - ジョブ起動前処理public void setPostJobProcessor(SupportProcessor postJobProcessor)
postJobProcessor - ジョブ起動前処理public void setJobParametersSplitStr(java.lang.String jobParametersSplitStr)
jobParametersSplitStr - ジョブパラメータの区切り文字protected org.springframework.context.ConfigurableApplicationContext getFrameworkFactory()
public void setThrowableHandler(ThrowableHandler throwableHandler)
throwableHandler - Throwableハンドラ| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||