org.axonframework.commandhandling.disruptor

Class AggregateBlacklistedException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.axonframework.common.AxonException

org.axonframework.common.AxonTransientException

org.axonframework.commandhandling.disruptor.AggregateStateCorruptedException

org.axonframework.commandhandling.disruptor.AggregateBlacklistedException

All Implemented Interfaces:

Serializable

public class AggregateBlacklistedException
extends AggregateStateCorruptedException

Exception indicating that an aggregate has been blacklisted by the DisruptorCommandBus. The cause of the blacklisting is provided in the Throwable.getCause() of the exception.

Aggregates are blacklisted when the DisruptorCommandBus cannot guarantee that the state of the aggregate in its cache is correct. A cleanup notification will be handled by the disruptor to recover from this, by clearing the cached data of the aggregate. After the cached information has been cleared, the blacklist status is removed.

It is generally safe to retry any commands that resulted in this exception, unless the cause is clearly non-transient.

Since:

2.0

Author:

Allard Buijze

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AggregateBlacklistedException(Object aggregateIdentifier, String message, Throwable cause) Initializes the exception with given aggregateIdentifier, given explanatory message and cause.

Method Summary

Methods inherited from class org.axonframework.commandhandling.disruptor.AggregateStateCorruptedException

getAggregateIdentifier

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateBlacklistedException

public AggregateBlacklistedException(Object aggregateIdentifier,
                             String message,
                             Throwable cause)

Initializes the exception with given aggregateIdentifier, given explanatory message and cause.

Parameters:

aggregateIdentifier - The identifier of the blacklisted aggregate

message - The message explaining why the blacklisting occurred

cause - The cause of the blacklist