| Package | Description |
|---|---|
| org.axonframework.commandhandling.disruptor |
| Modifier and Type | Method and Description |
|---|---|
CommandHandlingEntry |
CommandHandlingEntry.Factory.newInstance() |
| Modifier and Type | Method and Description |
|---|---|
void |
SerializerHandler.onEvent(CommandHandlingEntry event,
long sequence,
boolean endOfBatch) |
void |
EventPublisher.onEvent(CommandHandlingEntry entry,
long sequence,
boolean endOfBatch) |
void |
CommandHandlerInvoker.onEvent(CommandHandlingEntry entry,
long sequence,
boolean endOfBatch) |
| Constructor and Description |
|---|
BlacklistDetectingCallback(CommandCallback<R> delegate,
CommandMessage command,
com.lmax.disruptor.RingBuffer<CommandHandlingEntry> ringBuffer,
DisruptorCommandBus commandBus,
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-2014. All Rights Reserved.