public class SimpleJobOperator extends java.lang.Object implements JobOperator, org.springframework.beans.factory.InitializingBean
コンストラクターと説明 |
---|
SimpleJobOperator() |
修飾子と型 | メソッドと説明 |
---|---|
JobExecution | abandon(long jobExecutionId) JobExecution を ABANDONED としてマークします。 |
void | afterPropertiesSet() 必須プロパティを確認してください。 |
java.util.List<java.lang.Long> | getExecutions(long instanceId) 特定の JobInstance に関連付けられた JobExecutions を、作成順(したがって、通常は実行順)でリストします。 |
java.util.List<java.lang.Long> | getJobInstances(java.lang.String jobName, int start, int count) 指定されたジョブ名の JobInstances を、作成とは逆の順序で(したがって、通常は最初に実行されたときに)リストします。 |
java.util.Set<java.lang.String> | getJobNames() JobOperator.start(String, String) で起動できる使用可能なジョブ名をリストします。 |
java.lang.String | getParameters(long executionId) JobParameters を読みやすい文字列として取得します。 |
java.util.Set<java.lang.Long> | getRunningExecutions(java.lang.String jobName) 指定されたジョブ名で実行中のすべての JobExecutions の ID 値を取得します。 |
java.util.Map<java.lang.Long,java.lang.String> | getStepExecutionSummaries(long executionId) JobExecution に属する StepExecution インスタンスを、指定された ID で要約し、ステータス、開始時刻、終了時刻などの詳細を示します。 |
java.lang.String | getSummary(long executionId) 提供された ID で JobExecution を要約し、ステータス、開始時間と終了時間などの詳細を示します。 |
java.lang.Long | restart(long executionId) 失敗または停止した JobExecution を再起動します。 |
void | setJobExplorer(JobExplorer jobExplorer) JobExplorer のパブリック setter。 |
void | setJobLauncher(JobLauncher jobLauncher) JobLauncher のパブリック setter。 |
void | setJobParametersConverter(JobParametersConverter jobParametersConverter) JobParametersConverter のパブリック setter。 |
void | setJobRegistry(ListableJobLocator jobRegistry) ListableJobLocator のパブリック setter。 |
void | setJobRepository(JobRepository jobRepository) |
java.lang.Long | start(java.lang.String jobName, java.lang.String parameters) 指定されたパラメーターを使用して、ジョブの新しいインスタンスを開始します。 |
java.lang.Long | startNextInstance(java.lang.String jobName) 指定されたジョブに接続された JobParametersIncrementer によって決定される JobInstance のシーケンスで次を起動します。 |
boolean | stop(long executionId) 指定された ID を使用して JobExecution に停止信号を送信します。 |
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
InitializingBean.afterPropertiesSet()
public void setJobParametersConverter(JobParametersConverter jobParametersConverter)
JobParametersConverter
のパブリック setter。jobParametersConverter
- 設定する JobParametersConverter
public void setJobRegistry(ListableJobLocator jobRegistry)
ListableJobLocator
のパブリック setter。jobRegistry
- 設定する ListableJobLocator
public void setJobExplorer(JobExplorer jobExplorer)
JobExplorer
のパブリック setter。jobExplorer
- 設定する JobExplorer
public void setJobRepository(JobRepository jobRepository)
public void setJobLauncher(JobLauncher jobLauncher)
JobLauncher
のパブリック setter。jobLauncher
- 設定する JobLauncher
public java.util.List<java.lang.Long> getExecutions(long instanceId) throws NoSuchJobInstanceException
JobOperator
JobInstance
に関連付けられた JobExecutions
を、作成順(したがって、通常は実行順)でリストします。JobOperator
の getExecutions
instanceId
- JobInstance
の IDJobExecutions
の ID 値 NoSuchJobInstanceException
- instanceId
に関連付けられた JobInstance
が見つからない場合。public java.util.Set<java.lang.String> getJobNames()
JobOperator
JobOperator.start(String, String)
で起動できる使用可能なジョブ名をリストします。JobOperator
の getJobNames
public java.util.List<java.lang.Long> getJobInstances(java.lang.String jobName, int start, int count) throws NoSuchJobException
JobOperator
JobInstances
を、作成とは逆の順序で(したがって、通常は最初に実行されたときに)リストします。JobOperator
の getJobInstances
jobName
- すべてのインスタンスが持つジョブ名 start
- インスタンスの開始インデックス count
- 返す値の最大数 JobInstances
の ID 値 NoSuchJobException
- jobName の JobInstance
が存在しない場合にスローされます。public java.lang.String getParameters(long executionId) throws NoSuchJobExecutionException
JobOperator
JobParameters
を読みやすい文字列として取得します。JobOperator
の getParameters
executionId
- 既存の JobExecution
の IDNoSuchJobExecutionException
- ID が JobExecution
に関連付けられていなかった場合 public java.util.Set<java.lang.Long> getRunningExecutions(java.lang.String jobName) throws NoSuchJobException
JobOperator
JobExecutions
の ID 値を取得します。JobOperator
の getRunningExecutions
jobName
- 検索するジョブの名前 JobExecution
インスタンスの ID 値 NoSuchJobException
- そのジョブ名を持つ JobExecutions
がない場合 public java.util.Map<java.lang.Long,java.lang.String> getStepExecutionSummaries(long executionId) throws NoSuchJobExecutionException
JobOperator
JobExecution
に属する StepExecution
インスタンスを、指定された ID で要約し、ステータス、開始時刻、終了時刻などの詳細を示します。JobOperator
の getStepExecutionSummaries
executionId
- 既存の JobExecution
の IDNoSuchJobExecutionException
- 指定された ID の JobExecution
がない場合 public java.lang.String getSummary(long executionId) throws NoSuchJobExecutionException
JobOperator
JobExecution
を要約し、ステータス、開始時間と終了時間などの詳細を示します。JobOperator
の getSummary
executionId
- 既存の JobExecution
の IDNoSuchJobExecutionException
- 指定された ID の JobExecution
がない場合 public java.lang.Long restart(long executionId) throws JobInstanceAlreadyCompleteException, NoSuchJobExecutionException, NoSuchJobException, JobRestartException, JobParametersInvalidException
JobOperator
JobExecution
を再起動します。指定された ID が存在しないか、通常の状況ですでに正常に完了した JobInstance
に対応する場合、例外で失敗します。JobOperator
の restart
executionId
- 失敗または停止した JobExecution
の IDJobExecution
の IDJobInstanceAlreadyCompleteException
- ジョブがすでに正常に完了した場合 NoSuchJobExecutionException
- ID が JobExecution
に関連付けられていなかった場合 NoSuchJobException
- JobExecution
は見つかったが、対応する Job
が起動に使用できなくなった場合 JobRestartException
- 再起動時に特定できないエラーが発生した場合 (たとえば破損または一貫性のない再起動データ)JobParametersInvalidException
- パラメーターがこのジョブに有効でない場合 public java.lang.Long start(java.lang.String jobName, java.lang.String parameters) throws NoSuchJobException, JobInstanceAlreadyExistsException, JobParametersInvalidException
JobOperator
JobOperator
の start
jobName
- 起動する Job
の名前 parameters
- 起動するためのパラメーター (カンマまたは改行で区切られた名前 = 値のペア)JobExecution
の IDNoSuchJobException
- 指定された名前の Job
がない場合 JobInstanceAlreadyExistsException
- この名前とパラメーターのジョブインスタンスがすでに存在する場合 JobParametersInvalidException
- ジョブパラメーターのいずれかが無効な場合にスローされます。public java.lang.Long startNextInstance(java.lang.String jobName) throws NoSuchJobException, UnexpectedJobExecutionException, JobParametersInvalidException
JobOperator
JobParametersIncrementer
によって決定される JobInstance
のシーケンスで次を起動します。前のインスタンスがまだ障害状態にある場合、このメソッドは新しいインスタンスを作成し、(JobParametersIncrementer
が機能している限り)異なるパラメーターで実行する必要があります。JobOperator
の startNextInstance
jobName
- 起動するジョブの名前 JobExecution
IDNoSuchJobException
- 利用可能なそのようなジョブ定義がない場合 UnexpectedJobExecutionException
- 予期しない状況が発生した場合 JobParametersInvalidException
- ジョブパラメーターの一部が無効な場合にスローされます。@Transactional public boolean stop(long executionId) throws NoSuchJobExecutionException, JobExecutionNotRunningException
JobOperator
JobExecution
に停止信号を送信します。このメソッドが true を返した場合、シグナルは正常に送信されますが、ジョブが停止したことを意味するわけではありません。それを確認する唯一の方法は、ジョブの実行ステータスをポーリングすることです。JobOperator
の stop
executionId
- 実行中の JobExecution
の IDNoSuchJobExecutionException
- 指定された ID を持つ JobExecution
がない場合 JobExecutionNotRunningException
- JobExecution
が実行されていない場合 (止められない)public JobExecution abandon(long jobExecutionId) throws NoSuchJobExecutionException, JobExecutionAlreadyRunningException
JobOperator
JobExecution
を ABANDONED としてマークします。プロセスが停止したために停止信号が無視された場合、これは(STOPPED とは対照的に)ジョブを終了済みとしてマークする最良の方法です。破棄されたジョブの実行は、フレームワークによって再開できません。JobOperator
の abandon
jobExecutionId
- 中止するジョブ実行 IDJobExecution
NoSuchJobExecutionException
- jobExecutionId のジョブ実行がない場合にスローされます。JobExecutionAlreadyRunningException
- ジョブが実行中の場合 (最初に停止する必要があります)