public abstract class AbstractJob extends java.lang.Object implements Job, StepLocator, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean
Job
インターフェースの抽象実装。ここでは、JobRepository
、JobExecutionListener
、さまざまな構成パラメーターなどの一般的な依存関係を設定します。一般的なエラー処理とリスナー呼び出しアクティビティは、実装から抽象化されています。修飾子と型 | フィールドと説明 |
---|---|
protected static org.apache.commons.logging.Log | logger |
コンストラクターと説明 |
---|
AbstractJob() デフォルトコンストラクター。 |
AbstractJob(java.lang.String name) 名前をすぐに追加するための便利なコンストラクター(必須ですが、最終的なものではありません)。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() 必須プロパティをアサートする: JobRepository 。 |
protected abstract void | doExecute(JobExecution execution) サブクラスが処理ロジックに集中し、リスナーとリポジトリ呼び出しを無視できるようにする拡張ポイント。 |
void | execute(JobExecution execution) 指定されたジョブを実行し、すべてのリスナーとリポジトリの呼び出しを処理し、実際の処理を doExecute(JobExecution) に委譲します。 |
protected ExitStatus | getDefaultExitStatusForFailure(java.lang.Throwable ex, JobExecution execution) throwable から ExitStatus へのデフォルトのマッピング。 |
JobParametersIncrementer | getJobParametersIncrementer() クライアントがシーケンスの次の実行のために新しいパラメーターを生成する必要がある場合、このインクリメンターを使用できます。 |
JobParametersValidator | getJobParametersValidator() JobExecution のジョブパラメーターのバリデーター。 |
protected JobRepository | getJobRepository() サブクラスがジョブリポジトリにアクセスするための簡易メソッド。 |
java.lang.String | getName() |
abstract Step | getStep(java.lang.String stepName) 指定された名前のステップを取得します。 |
abstract java.util.Collection<java.lang.String> | getStepNames() ステップ名を取得します。 |
protected StepExecution | handleStep(Step step, JobExecution execution) 現在の JobExecution のコンテキストで特定のステップの処理を委譲するためのサブクラスの簡易メソッド。 |
boolean | isRestartable() 少なくとも原則として、このジョブを再開できるかどうかを示すフラグ。 |
void | registerJobExecutionListener(JobExecutionListener listener) JobExecutionListener コールバックに単一のリスナーを登録します。 |
void | setBeanName(java.lang.String name) name プロパティがまだ設定されていない場合は設定します。 |
void | setJobExecutionListeners(JobExecutionListener[] listeners) JobExecutionListener を挿入するためのパブリック setter。 |
void | setJobParametersIncrementer(JobParametersIncrementer jobParametersIncrementer) JobParametersIncrementer のパブリック setter。 |
void | setJobParametersValidator(JobParametersValidator jobParametersValidator) ジョブパラメーターのバリデータ。 |
void | setJobRepository(JobRepository jobRepository) ジョブの存続期間中にバッチメタドメイン(ジョブ、ステップ、実行)の状態を管理するために必要な JobRepository のパブリック setter。 |
void | setName(java.lang.String name) name プロパティを設定します。 |
void | setRestartable(boolean restartable) ジョブが以前に失敗した場合でも、ジョブが再起動しないようにするブールフラグ。 |
java.lang.String | toString() |
public AbstractJob()
public AbstractJob(java.lang.String name)
name
- ジョブの名前 public void setJobParametersValidator(JobParametersValidator jobParametersValidator)
DefaultJobParametersValidator
です。jobParametersValidator
- バリデーターインスタンス public void afterPropertiesSet() throws java.lang.Exception
JobRepository
。org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
InitializingBean.afterPropertiesSet()
public void setBeanName(java.lang.String name)
org.springframework.beans.factory.BeanNameAware
の setBeanName
BeanNameAware.setBeanName(java.lang.String)
public void setName(java.lang.String name)
name
- ジョブに関連付ける名前。setBeanName(java.lang.String)
public abstract Step getStep(java.lang.String stepName)
StepLocator
の getStep
stepName
- ステップの名前 public abstract java.util.Collection<java.lang.String> getStepNames()
StepLocator
の getStepNames
public JobParametersValidator getJobParametersValidator()
Job
JobExecution
のジョブパラメーターのバリデーター。ジョブのクライアントは、実行前または実行中に起動のパラメーターを検証する必要がある場合があります。Job
の getJobParametersValidator
null
)public void setRestartable(boolean restartable)
restartable
- 設定するフラグの値 (デフォルト true)public boolean isRestartable()
Job
Job
の isRestartable
Job.isRestartable()
public void setJobParametersIncrementer(JobParametersIncrementer jobParametersIncrementer)
JobParametersIncrementer
のパブリック setter。jobParametersIncrementer
- 設定する JobParametersIncrementer
@Nullable public JobParametersIncrementer getJobParametersIncrementer()
Job
null
になります。Job
の getJobParametersIncrementer
public void setJobExecutionListeners(JobExecutionListener[] listeners)
JobExecutionListener
を挿入するためのパブリック setter。それらはすべて、ジョブの適切な時点でリスナーコールバックが与えられます。listeners
- 設定するリスナー。public void registerJobExecutionListener(JobExecutionListener listener)
JobExecutionListener
コールバックに単一のリスナーを登録します。listener
- JobExecutionListener
public void setJobRepository(JobRepository jobRepository)
JobRepository
のパブリック setter。jobRepository
- ジョブの実行中に使用するリポジトリ protected JobRepository getJobRepository()
protected abstract void doExecute(JobExecution execution) throws JobExecutionException
handleStep(Step, JobExecution)
に委譲します。execution
- 現在の JobExecution
JobExecutionException
- 致命的なバッチフレームワークエラーを通知する (ビジネスまたは検証の例外ではない)public final void execute(JobExecution execution)
doExecute(JobExecution)
に委譲します。Job
の execute
execution
- JobExecution
StartLimitExceededException
- いずれかのステップの開始制限を超えた場合 Job.execute(JobExecution)
protected final StepExecution handleStep(Step step, JobExecution execution) throws JobInterruptedException, JobRestartException, StartLimitExceededException
JobExecution
のコンテキストで特定のステップの処理を委譲するための簡易メソッド。このメソッドのクライアントは、JobRepository
にアクセスする必要はありません。また、再起動時に実行コンテキストに入力したり、中断された状態(ジョブまたはステップの実行中)を検出したりする必要もありません。step
- 実行する Step
execution
- 現在の JobExecution
StepExecution
JobInterruptedException
- JobExecution
が中断された場合、特に BatchStatus.ABANDONED
または BatchStatus.STOPPING
が検出された場合 StartLimitExceededException
- このステップの開始制限を超えている場合 JobRestartException
- ジョブが以前の失敗と矛盾した状態にある場合 protected ExitStatus getDefaultExitStatusForFailure(java.lang.Throwable ex, JobExecution execution)
ExitStatus
へのデフォルトのマッピング。ex
- 失敗の原因 execution
- JobExecution
インスタンス。ExitStatus
public java.lang.String toString()
java.lang.Object
の toString