フィールドの詳細

• ロガー

  protected final org.apache.commons.logging.Log logger

コンストラクターの詳細

• RetryTemplate

  public RetryTemplate()

メソッドの詳細

• 最後の例外をスローする

  public void setThrowLastExceptionOnExhausted(boolean throwLastExceptionOnExhausted)

  パラメーター:

  throwLastExceptionOnExhausted - throwLastExceptionOnExhausted を設定する

• setRetryContextCache

  public void setRetryContextCache(RetryContextCache retryContextCache)

  RetryContextCache のパブリック setter。

  パラメーター:

  retryContextCache - 設定する RetryContextCache

• setListeners

  public void setListeners(RetryListener[] listeners)

  リスナー用の Setter。リスナーは再試行ブロックの前後 (つまり、すべての試行の前後)、エラー時 (すべての試行) に実行されます。

  パラメーター:

  listeners - RetryListener s

  関連事項:

  RetryListener

• registerListener

  public void registerListener(RetryListener listener)

  追加のリスナーを登録します。

  パラメーター:

  listener - RetryListener

  関連事項:

  setListeners(RetryListener[])

• setBackOffPolicy

  public void setBackOffPolicy(BackOffPolicy backOffPolicy)

  BackOffPolicy の Setter。

  パラメーター:

  backOffPolicy - BackOffPolicy

• setRetryPolicy

  public void setRetryPolicy(RetryPolicy retryPolicy)

  RetryPolicy の Setter。

  パラメーター:

  retryPolicy - RetryPolicy

• 実行する

  public final <T,E extends Throwable (標準 Javadoc) (英語)  > T execute(RetryCallback<T,E> retryCallback)
                                          throws E extends Throwable (標準 Javadoc) (英語)  

  コールバックが成功するか、ポリシーによって停止するように指示されるまで、コールバックの実行を続けます。停止する場合は、コールバックによってスローされた最新の例外が再スローされます。

  次で指定:

  インターフェース RetryOperations の execute 

  型パラメーター:

  T - 戻り値

  E - スローする例外

  パラメーター:

  retryCallback - RetryCallback

  戻り値:

  呼び出しが成功したときに RetryCallback によって返される値。

  例外:

  TerminatedRetryException - 再試行がリスナーによって手動で終了された場合。

  E - 再試行が失敗したときに RetryCallback によって発生した Exception (標準 Javadoc) (英語) 。

  E extends Throwable (標準 Javadoc) (英語)

  関連事項:

  RetryOperations.execute(RetryCallback)

• 実行する

  public final <T,E extends Throwable (標準 Javadoc) (英語)  > T execute(RetryCallback<T,E> retryCallback,
                                                 RecoveryCallback<T> recoveryCallback)
                                          throws E extends Throwable (標準 Javadoc) (英語)  

  コールバックが成功するか、ポリシーによって停止するように指示されるまでコールバックの実行を続けます。停止するように指示された場合は、リカバリコールバックが実行されます。

  次で指定:

  インターフェース RetryOperations の execute 

  型パラメーター:

  T - 返す型

  E - 例外の種類

  パラメーター:

  retryCallback - RetryCallback

  recoveryCallback - RecoveryCallback

  戻り値:

  呼び出しが成功した場合に RetryCallback によって返される値、それ以外の場合に RecoveryCallback によって返される値。

  例外:

  TerminatedRetryException - 再試行がリスナーによって手動で終了された場合。

  E - 発生した Exception (標準 Javadoc) (英語)

  E extends Throwable (標準 Javadoc) (英語)

  関連事項:

  RetryOperations.execute(RetryCallback, RecoveryCallback)

• 実行する

  public final <T,E extends Throwable (標準 Javadoc) (英語)  > T execute(RetryCallback<T,E> retryCallback,
                                                 RetryState retryState)
                                          throws E extends Throwable (標準 Javadoc) (英語)  ,
                                                 ExhaustedRetryException

  ポリシーで許可されている場合はコールバックを 1 回実行し、発生した例外を再スローして、クライアントが後で同じタスクを再提示できるようにします。

  次で指定:

  インターフェース RetryOperations の execute 

  型パラメーター:

  T - 戻り値の型

  E - 返される例外の型

  パラメーター:

  retryCallback - RetryCallback

  retryState - RetryState

  戻り値:

  呼び出しが成功した場合に RetryCallback によって返される値、それ以外の場合に RecoveryCallback によって返される値。

  例外:

  ExhaustedRetryException - 再試行回数が上限に達した場合。

  E - RecoveryCallback によって発生した Exception (標準 Javadoc) (英語) 。

  E extends Throwable (標準 Javadoc) (英語)

  関連事項:

  RetryOperations.execute(RetryCallback, RetryState)

• 実行する

  public final <T,E extends Throwable (標準 Javadoc) (英語)  > T execute(RetryCallback<T,E> retryCallback,
                                                 RecoveryCallback<T> recoveryCallback,
                                                 RetryState retryState)
                                          throws E extends Throwable (標準 Javadoc) (英語)  ,
                                                 ExhaustedRetryException

  ポリシーで許可されている場合はコールバックを 1 回実行し、発生した例外を再スローして、クライアントが後で同じタスクを再提示できるようにします。

  次で指定:

  インターフェース RetryOperations の execute 

  型パラメーター:

  T - 戻り値の型

  E - 例外型

  パラメーター:

  retryCallback - RetryCallback

  recoveryCallback - RecoveryCallback

  retryState - RetryState

  戻り値:

  呼び出しが成功した場合に RetryCallback によって返される値、それ以外の場合に RecoveryCallback によって返される値。

  例外:

  E - 再試行が失敗したときに RecoveryCallback によって発生した Exception (標準 Javadoc) (英語) 。

  E extends Throwable (標準 Javadoc) (英語)

  ExhaustedRetryException

  関連事項:

  RetryOperations.execute(RetryCallback, RetryState)

• doExecute

  protected <T,E extends Throwable (標準 Javadoc) (英語)  > T doExecute(RetryCallback<T,E> retryCallback,
                                                RecoveryCallback<T> recoveryCallback,
                                                RetryState state)
                                         throws E extends Throwable (標準 Javadoc) (英語)  ,
                                                ExhaustedRetryException

  ポリシーで許可されている場合はコールバックを 1 回実行し、そうでない場合はリカバリコールバックを実行します。

  型パラメーター:

  T - 戻り値の型

  E - スローする例外の種類

  パラメーター:

  recoveryCallback - RecoveryCallback

  retryCallback - RetryCallback

  state - RetryState

  戻り値:

  T 再試行された値

  例外:

  ExhaustedRetryException - 再試行回数が上限に達した場合。

  E - 再試行操作が失敗した場合の例外

  E extends Throwable (標準 Javadoc) (英語)

  関連事項:

  RetryOperations.execute(RetryCallback, RecoveryCallback, RetryState)

• canRetry

  protected boolean canRetry(RetryPolicy retryPolicy,
                             RetryContext context)

  進行中の再試行を続行するかどうかを決定します。このメソッドは、RetryCallback が実行される前に、バックオフとオープンインターセプターの後に呼び出されます。

  パラメーター:

  retryPolicy - 適用するポリシー

  context - 現在の再試行コンテキスト

  戻り値:

  試行を続行できる場合は true

• 閉じる

  protected void close(RetryPolicy retryPolicy,
                       RetryContext context,
                       RetryState state,
                       boolean succeeded)

  必要に応じてキャッシュをクリーンアップし、提供されたコンテキストを閉じます (フラグが処理が成功したことを示している場合)。

  パラメーター:

  retryPolicy - RetryPolicy

  context - RetryContext

  state - RetryState

  succeeded - クローズが成功したかどうか

• registerThrowable

  protected void registerThrowable(RetryPolicy retryPolicy,
                                   RetryState state,
                                   RetryContext context,
                                   Throwable (標準 Javadoc) (英語)   e)

• 開く

  protected RetryContext open(RetryPolicy retryPolicy,
                              RetryState state)

  状態が null でない場合は、キャッシュ内の既存の値を確認して RetryPolicy に委譲します。

  パラメーター:

  state - RetryState

  retryPolicy - コンテキスト作成を委譲する RetryPolicy

  戻り値:

  再試行コンテキスト（新しいもの、または同じ状態に遭遇した前回に使用されたもの）

• handleRetryExhausted

  protected <T> T handleRetryExhausted(RecoveryCallback<T> recoveryCallback,
                                       RetryContext context,
                                       RetryState state)
                                throws Throwable (標準 Javadoc) (英語)  

  最終試行が失敗した後に実行するアクション。状態がある場合はキャッシュをクリーンアップします。回復コールバックがある場合はそれを実行し、その結果を返します。それ以外の場合は例外をスローします。

  型パラメーター:

  T - 分類する型

  パラメーター:

  recoveryCallback - 回復のためのコールバック (null である可能性があります)

  context - 現在の再試行コンテキスト

  state - RetryState

  戻り値:

  T 返すペイロード

  例外:

  Exception (標準 Javadoc) (英語)  - コールバックがコールバックを実行し、コールバックが存在せず状態が null の場合は、コンテキストからの最後の例外

  ExhaustedRetryException - 状態が null でなく、回復コールバックがない場合

  Throwable (標準 Javadoc) (英語)

• 再投球

  protected <E extends Throwable (標準 Javadoc) (英語)  > void rethrow(RetryContext context,
                                               String (標準 Javadoc) (英語)   message)
                                        throws E extends Throwable (標準 Javadoc) (英語)  

  例外:

  E extends Throwable (標準 Javadoc) (英語)

• shouldRethrow

  protected boolean shouldRethrow(RetryPolicy retryPolicy,
                                  RetryContext context,
                                  RetryState state)

  RetryCallback で例外をキャッチした後の動作を決定するサブクラスの拡張ポイント。通常のステートレス動作では再スローは行われませんが、状態がある場合は再スローされます。

  パラメーター:

  retryPolicy - 再試行ポリシー

  context - 現在のコンテキスト

  state - 現在の retryState

  戻り値:

  状態が null ではないが、サブクラスが別の選択をする可能性がある場合は true