org.axonframework.commandhandling.gateway

Class NonTransientExceptionClassesPredicate

java.lang.Object

org.axonframework.commandhandling.gateway.NonTransientExceptionClassesPredicate

All Implemented Interfaces:

Predicate<Throwable>

Direct Known Subclasses:

AxonNonTransientExceptionClassesPredicate

public class NonTransientExceptionClassesPredicate
extends Object
implements Predicate<Throwable>

A predicate for checking non-transiency of a failure comparing it against configured concrete classes.

Comparison checks if any of configured classes is assignable from a tested failure instance.

This predicate is intended to be used for configuring RetryScheduler implementations like in the following example:

 IntervalRetryScheduler myRetryScheduler = IntervalRetryScheduler
      .builder()
      .retryExecutor(new ScheduledThreadPoolExecutor(1))
      .nonTransientFailurePredicate(
          new NonTransientExceptionClassesPredicate(
              AxonNonTransientException.class, NullPointerException.class, IllegalArgumentException.class,
              IllegalStateException.class
          )
      )
      .build();
 

Since:

4.6.0

Author:

Damir Murat

Constructor Summary

Constructors

Constructor and Description
NonTransientExceptionClassesPredicate(Class<? extends Throwable>... nonTransientFailures) Initialize the predicate with class(es) that are considered as non-transient.

Method Summary

Modifier and Type	Method and Description
protected List<Class<? extends Throwable>>	getNonTransientFailures() Fetches a configured list of non-transient failures.
protected boolean	isNonTransientFailure(Throwable failure) Checks if the provided failure is considered non-transient.
boolean	test(Throwable failure)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Constructor Detail

NonTransientExceptionClassesPredicate

@SafeVarargs
public NonTransientExceptionClassesPredicate(Class<? extends Throwable>... nonTransientFailures)

Initialize the predicate with class(es) that are considered as non-transient.

Parameters:

nonTransientFailures - vararg list of non-transient class(es)

Method Detail

test

public boolean test(Throwable failure)

Specified by:

test in interface Predicate<Throwable>

isNonTransientFailure

protected boolean isNonTransientFailure(Throwable failure)

Checks if the provided failure is considered non-transient.

This implementation checks if any configured exception class is assignable to the provided failure.

Parameters:

failure - The failure to check for non-transiency

Returns:

a boolean indicating if provided failure is non-transient (true) or not (false)

getNonTransientFailures

protected List<Class<? extends Throwable>> getNonTransientFailures()

Fetches a configured list of non-transient failures.

Useful if one wants to override isNonTransientFailure(Throwable).

Returns:

a configured list of non-transient failures.