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.
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(CommandMessage<? extends C> commandMessage, CommandResultMessage<? extends R> commandResultMessage)
public boolean hasDelegate()
trueif this callback has a delegate, otherwise
Copyright © 2010–2021. All rights reserved.