public class BatchRetryTemplate
extends java.lang.Object
implements org.springframework.retry.RetryOperations
RetryState
はコンポジットであり、障害が発生すると、コンポジット内のすべてのキーが「同じブラシでタール化」されます。以前に失敗したキーのいずれかを使用して実行しようとすると、新しい試行が発生し、前の状態を使用して RetryPolicy
がチェックされます。失敗したアイテムの 1 つが最終的に成功した場合、その試行の現在のコンポジット内の他のアイテムは(通常どおり)コンテキストキャッシュからクリアされますが、元の失敗したアイテムのエントリがキャッシュに残っている可能性があります。これは、同じバッチ内の他のアイテムが最初に致命的に失敗するため、失敗を引き起こさなかったアイテムが再試行されないことを意味する場合があります。コンストラクターと説明 |
---|
BatchRetryTemplate() |
修飾子と型 | メソッドと説明 |
---|---|
boolean | canRetry(org.springframework.retry.RetryContext context) |
static java.util.List<org.springframework.retry.RetryState> | createState(java.util.List<?> keys) |
static java.util.List<org.springframework.retry.RetryState> | createState(java.util.List<?> keys, org.springframework.classify.Classifier<? super java.lang.Throwable,java.lang.Boolean> classifier) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback, java.util.Collection<org.springframework.retry.RetryState> states) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback, java.util.Collection<org.springframework.retry.RetryState> states) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback, org.springframework.retry.RetryState retryState) |
<T,E extends java.lang.Throwable> | execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RetryState retryState) |
void | registerListener(org.springframework.retry.RetryListener listener) |
void | setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) |
void | setListeners(org.springframework.retry.RetryListener[] listeners) |
void | setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) |
void | setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy) |
public <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback, java.util.Collection<org.springframework.retry.RetryState> states) throws E extends java.lang.Throwable, java.lang.Exception
E extends java.lang.Throwable
java.lang.Exception
public <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback, java.util.Collection<org.springframework.retry.RetryState> states) throws E extends java.lang.Throwable, java.lang.Exception
E extends java.lang.Throwable
java.lang.Exception
public final <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback, org.springframework.retry.RetryState retryState) throws E extends java.lang.Throwable
org.springframework.retry.RetryOperations
の execute
E extends java.lang.Throwable
public final <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RecoveryCallback<T> recoveryCallback) throws E extends java.lang.Throwable
org.springframework.retry.RetryOperations
の execute
E extends java.lang.Throwable
public final <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback, org.springframework.retry.RetryState retryState) throws E extends java.lang.Throwable, org.springframework.retry.ExhaustedRetryException
org.springframework.retry.RetryOperations
の execute
E extends java.lang.Throwable
org.springframework.retry.ExhaustedRetryException
public final <T,E extends java.lang.Throwable> T execute(org.springframework.retry.RetryCallback<T,E> retryCallback) throws E extends java.lang.Throwable
org.springframework.retry.RetryOperations
の execute
E extends java.lang.Throwable
public static java.util.List<org.springframework.retry.RetryState> createState(java.util.List<?> keys)
public static java.util.List<org.springframework.retry.RetryState> createState(java.util.List<?> keys, org.springframework.classify.Classifier<? super java.lang.Throwable,java.lang.Boolean> classifier)
public void registerListener(org.springframework.retry.RetryListener listener)
public void setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
public void setListeners(org.springframework.retry.RetryListener[] listeners)
public void setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
public void setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
public boolean canRetry(org.springframework.retry.RetryContext context)