Package | Description |
---|---|
dev.failsafe |
APIs for performing failsafe executions.
|
Modifier and Type | Method and Description |
---|---|
EventListener<ExecutionCompletedEvent<R>> |
RetryPolicyConfig.getAbortListener()
Returns the abort event listener.
|
EventListener<CircuitBreakerStateChangedEvent> |
CircuitBreakerConfig.getCloseListener()
Returns the close event listener.
|
EventListener<ExecutionAttemptedEvent<R>> |
RetryPolicyConfig.getFailedAttemptListener()
Returns the failed attempt event listener.
|
EventListener<ExecutionAttemptedEvent<R>> |
FallbackConfig.getFailedAttemptListener()
Returns the failed attempt event listener.
|
EventListener<ExecutionCompletedEvent<R>> |
PolicyConfig.getFailureListener()
Returns the failure listener.
|
EventListener<CircuitBreakerStateChangedEvent> |
CircuitBreakerConfig.getHalfOpenListener()
Returns the half-open event listener.
|
EventListener<CircuitBreakerStateChangedEvent> |
CircuitBreakerConfig.getOpenListener()
Returns the open event listener.
|
EventListener<ExecutionCompletedEvent<R>> |
RetryPolicyConfig.getRetriesExceededListener()
Returns the retries exceeded event listener.
|
EventListener<ExecutionAttemptedEvent<R>> |
RetryPolicyConfig.getRetryListener()
Returns the retry event listener.
|
EventListener<ExecutionScheduledEvent<R>> |
RetryPolicyConfig.getRetryScheduledListener()
Returns the retry scheduled event listener.
|
EventListener<ExecutionCompletedEvent<R>> |
PolicyConfig.getSuccessListener()
Returns the success listener.
|
Modifier and Type | Method and Description |
---|---|
RetryPolicyBuilder<R> |
RetryPolicyBuilder.onAbort(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when an execution is aborted. |
CircuitBreakerBuilder<R> |
CircuitBreakerBuilder.onClose(EventListener<CircuitBreakerStateChangedEvent> listener)
Calls the
listener when the circuit is closed. |
FailsafeExecutor<R> |
FailsafeExecutor.onComplete(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when an execution is complete. |
RetryPolicyBuilder<R> |
RetryPolicyBuilder.onFailedAttempt(EventListener<ExecutionAttemptedEvent<R>> listener)
Registers the
listener to be called when an execution attempt fails. |
FallbackBuilder<R> |
FallbackBuilder.onFailedAttempt(EventListener<ExecutionAttemptedEvent<R>> listener)
Registers the
listener to be called when the last execution attempt prior to the fallback failed. |
S |
PolicyBuilder.onFailure(EventListener<ExecutionCompletedEvent<R>> listener) |
FailsafeExecutor<R> |
FailsafeExecutor.onFailure(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when an execution fails. |
S |
PolicyListeners.onFailure(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when the policy fails to handle an execution. |
CircuitBreakerBuilder<R> |
CircuitBreakerBuilder.onHalfOpen(EventListener<CircuitBreakerStateChangedEvent> listener)
Calls the
listener when the circuit is half-opened. |
CircuitBreakerBuilder<R> |
CircuitBreakerBuilder.onOpen(EventListener<CircuitBreakerStateChangedEvent> listener)
Calls the
listener when the circuit is opened. |
RetryPolicyBuilder<R> |
RetryPolicyBuilder.onRetriesExceeded(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when an execution fails and the max retry attempts or max duration
are exceeded. |
RetryPolicyBuilder<R> |
RetryPolicyBuilder.onRetry(EventListener<ExecutionAttemptedEvent<R>> listener)
Registers the
listener to be called when a retry is about to be attempted. |
RetryPolicyBuilder<R> |
RetryPolicyBuilder.onRetryScheduled(EventListener<ExecutionScheduledEvent<R>> listener)
Registers the
listener to be called when a retry for an async call is about to be scheduled. |
S |
PolicyBuilder.onSuccess(EventListener<ExecutionCompletedEvent<R>> listener) |
FailsafeExecutor<R> |
FailsafeExecutor.onSuccess(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when an execution is successful. |
S |
PolicyListeners.onSuccess(EventListener<ExecutionCompletedEvent<R>> listener)
Registers the
listener to be called when the policy succeeds in handling an execution. |
Copyright © 2022. All rights reserved.