Package | Description |
---|---|
org.axonframework.commandhandling.disruptor |
Modifier and Type | Method and Description |
---|---|
void |
EventPublisher.onEvent(CommandHandlingEntry entry,
long sequence,
boolean endOfBatch) |
void |
CommandHandlerInvoker.onEvent(CommandHandlingEntry entry,
long sequence,
boolean endOfBatch) |
Constructor and Description |
---|
BlacklistDetectingCallback(CommandCallback<? super C,R> delegate,
com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer,
BiConsumer<CommandMessage<? extends C>,CommandCallback<? super C,R>> retryMethod,
boolean rescheduleOnCorruptState)
Initializes the callback which allows the given
command to be rescheduled on the given
ringBuffer if it failed due to a corrupt state. |
Copyright © 2010–2017. All rights reserved.