Package | Description |
---|---|
org.axonframework.commandhandling.disruptor | |
org.axonframework.contextsupport.spring |
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. |
Modifier and Type | Method and Description |
---|---|
void |
DisruptorCommandBusBeanDefinitionParser.RepositoryFactoryBean.setCommandBus(DisruptorCommandBus commandBus)
The DisruptorCommandBus instance to create the repository from.
|
Copyright © 2010-2014. All Rights Reserved.