R- The return value of the Command
C- The type of payload of the dispatched command
public class BlacklistDetectingCallback<C,R> extends Object implements CommandCallback<C,R>
|Constructor and Description|
Initializes the callback which allows the given
|Modifier and Type||Method and Description|
Indicates whether this callback has a delegate that needs to be notified of the command handling result
Invoked when command handling execution is completed.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public BlacklistDetectingCallback(CommandCallback<? super C,R> delegate, com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer, BiConsumer<CommandMessage<? extends C>,CommandCallback<? super C,R>> retryMethod, boolean rescheduleOnCorruptState)
commandto be rescheduled on the given
ringBufferif it failed due to a corrupt state.
delegate- The callback to invoke when an exception occurred
ringBuffer- The RingBuffer on which an Aggregate Cleanup should be scheduled when a corrupted aggregate state was detected
retryMethod- The method to reschedule a command if it was executed on a corrupt aggregate
rescheduleOnCorruptState- Whether the command should be retried if it has been executed against corrupt state
public void onResult(@Nonnull CommandMessage<? extends C> commandMessage, @Nonnull CommandResultMessage<? extends R> commandResultMessage)
public boolean hasDelegate()
trueif this callback has a delegate, otherwise
Copyright © 2010–2023. All rights reserved.