public class RetryHandler extends java.lang.Object implements Handler<java.lang.Object,java.lang.Object>
Retryableインタフェースを実装した例外をリトライ可能な例外と判断する。
リトライ処理の制御はRetryHandler.RetryContextを実装したクラスに委譲する。
RetryHandler.RetryContextを実装したクラスはRetryHandler.RetryContextFactoryから取得するので、
本クラスを使用する場合はRetryHandler.RetryContextFactoryオブジェクトをプロパティに設定すること。| 修飾子とタイプ | クラスと説明 |
|---|---|
static interface |
RetryHandler.RetryContext
リトライ処理を制御するインタフェース。
|
static interface |
RetryHandler.RetryContextFactory
リトライコンテキストを生成するインタフェース。
|
| コンストラクタと説明 |
|---|
RetryHandler() |
| 修飾子とタイプ | メソッドと説明 |
|---|---|
java.lang.Object |
handle(java.lang.Object data,
ExecutionContext context)
入力データに対する処理を実行する。
|
void |
setDestroyReader(boolean destroyReader)
リトライ時に
ExecutionContext上に設定されたDataReaderを破棄するか否かを設定する。。 |
void |
setRetryContextFactory(RetryHandler.RetryContextFactory retryContextFactory)
リトライコンテキストを生成する
RetryHandler.RetryContextFactoryオブジェクトを設定する。 |
void |
setRetryLimitExceededExitCode(int retryLimitExceededExitCode)
リトライ上限を超えた場合に使用する終了コード(プロセスを終了(
System.exit(int))する際に設定する値)を設定する。 |
void |
setRetryLimitExceededFailureCode(java.lang.String retryLimitExceededFailureCode)
リトライ上限を超えた場合に使用する障害コードを設定する。
|
public java.lang.Object handle(java.lang.Object data,
ExecutionContext context)
retryLimitExceededExitCodeプロパティと
retryLimitExceededFailureCodeプロパティを使用して
ProcessAbnormalEndを送出する。public void setDestroyReader(boolean destroyReader)
ExecutionContext上に設定されたDataReaderを破棄するか否かを設定する。。
本設定値にtrueを設定した場合、リトライ時にExecutionContext上に設定されたDataReaderを破棄(削除)する。
これにより、後続ハンドラでDataReaderが再生成される。destroyReader - リトライ時にリーダを破棄するか否かpublic void setRetryContextFactory(RetryHandler.RetryContextFactory retryContextFactory)
RetryHandler.RetryContextFactoryオブジェクトを設定する。retryContextFactory - リトライコンテキストを生成するRetryHandler.RetryContextFactoryオブジェクトpublic void setRetryLimitExceededExitCode(int retryLimitExceededExitCode)
System.exit(int))する際に設定する値)を設定する。retryLimitExceededExitCode - リトライ上限を超えた場合に使用する終了コード(プロセスを終了(System.exit(int))する際に設定する値)public void setRetryLimitExceededFailureCode(java.lang.String retryLimitExceededFailureCode)
retryLimitExceededFailureCode - リトライ上限を超えた場合に使用する障害コード