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

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

fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, 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