public class AggregateBlacklistedException extends AggregateStateCorruptedException
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.Constructor and Description |
---|
AggregateBlacklistedException(String aggregateIdentifier,
String message,
Throwable cause)
Initializes the exception with given
aggregateIdentifier , given explanatory message and cause . |
getAggregateIdentifier
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
public AggregateBlacklistedException(String aggregateIdentifier, String message, Throwable cause)
aggregateIdentifier
, given explanatory message
and cause
.aggregateIdentifier
- The identifier of the blacklisted aggregatemessage
- The message explaining why the blacklisting occurredcause
- The cause of the blacklistCopyright © 2010–2024. All rights reserved.