Uses of Class
org.axonframework.eventhandling.async.RetryPolicy

Packages that use RetryPolicy

org.axonframework.eventhandling.async
org.axonframework.saga.annotation

Uses of RetryPolicy in org.axonframework.eventhandling.async

Subclasses of RetryPolicy in org.axonframework.eventhandling.async

protected static class

EventProcessor.ProcessingResult Class indicating the result of Event Processing and the policy for resuming or retrying in case of errors.

Methods in org.axonframework.eventhandling.async that return RetryPolicy

RetryPolicy	ErrorHandler.handleError(Throwable exception, EventMessage<?> eventMessage, EventListener eventListener) Invoked when a handler or the unit of work throws an exception.
RetryPolicy	DefaultErrorHandler.handleError(Throwable exception, EventMessage<?> eventMessage, EventListener eventListener)
static RetryPolicy	RetryPolicy.proceed() Tells the scheduler to ignore the failure continue processing.
static RetryPolicy	RetryPolicy.retryAfter(long timeout, TimeUnit unit) This policy will roll back the Unit of Work (and the transaction), if any) and reschedule the event for processing.
static RetryPolicy	RetryPolicy.skip() This policy will roll back the Unit of Work (and the transaction) and skip the event altogether.

Constructors in org.axonframework.eventhandling.async with parameters of type RetryPolicy

DefaultErrorHandler(RetryPolicy retryPolicy)
Initializes the ErrorHandler, making it return the given retryPolicy when an error occurs.

EventProcessor.ProcessingResult(RetryPolicy retryPolicy, Throwable error)
Creates an instance requiring the given retryPolicy and reporting the given (optional) error to indicate a failure.

Uses of RetryPolicy in org.axonframework.saga.annotation

Methods in org.axonframework.saga.annotation that return RetryPolicy

RetryPolicy	RetryingErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception e)
RetryPolicy	ProceedingErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception e)
RetryPolicy	ErrorHandler.onErrorInvoking(Saga saga, EventMessage publishedEvent, int invocationCount, Exception exception) Invoked when an error occurs when a Saga instance is invoked.
RetryPolicy	RetryingErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception e)
RetryPolicy	ProceedingErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception e)
RetryPolicy	ErrorHandler.onErrorPreparing(Class<? extends Saga> sagaType, EventMessage<?> publishedEvent, int invocationCount, Exception exception) Invoked when an error occurs preparing Sagas.
RetryPolicy	RetryingErrorHandler.TimeoutConfiguration.retryPolicy() The retry policy to use between retries