Package | Description |
---|---|
org.axonframework.disruptor.commandhandling |
Modifier and Type | Method and Description |
---|---|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.bufferSize(int bufferSize)
Sets the buffer size to use.
|
static DisruptorCommandBus.Builder |
DisruptorCommandBus.builder()
Instantiate a Builder to be able to create a
DisruptorCommandBus . |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.cache(Cache cache)
Sets the
Cache in which loaded aggregates will be stored. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.commandTargetResolver(CommandTargetResolver commandTargetResolver)
Sets the
CommandTargetResolver that must be used to indicate which Aggregate instance will be
invoked by an incoming command. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.coolingDownPeriod(long coolingDownPeriod)
Sets the cooling down period in milliseconds.
|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<CommandMessage<?>>> dispatchInterceptors)
Configures
MessageDispatchInterceptor of generic type CommandMessage to use with the
DisruptorCommandBus when commands are dispatched. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.executor(Executor executor)
Sets the
Executor that provides the processing resources (Threads) for the components of the
DisruptorCommandBus . |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.invokerInterceptors(List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors)
Set the
MessageHandlerInterceptor of generic type CommandMessage to use with the
DisruptorCommandBus during in the invocation thread. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.invokerThreadCount(int invokerThreadCount)
Sets the number of Threads that should be used to invoke the Command Handlers.
|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the
MessageMonitor of generic type CommandMessage used the to monitor the command bus. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.producerType(com.lmax.disruptor.dsl.ProducerType producerType)
Sets the
ProducerType to use by the Disruptor . |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.publisherInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> publisherInterceptors)
Configures the
MessageHandlerInterceptor of generic type CommandMessage to use with the
DisruptorCommandBus during the publication of changes. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.publisherThreadCount(int publisherThreadCount)
Sets the number of Threads that should be used to store and publish the generated Events.
|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.rescheduleCommandsOnCorruptState(boolean rescheduleCommandsOnCorruptState)
Set the indicator specifying whether commands that failed because they were executed against potentially
corrupted aggregate state should be automatically rescheduled.
|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.rollbackConfiguration(RollbackConfiguration rollbackConfiguration)
Sets the
RollbackConfiguration which allows you to specify when a UnitOfWork should be rolled
back. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.transactionManager(TransactionManager transactionManager)
Sets the
TransactionManager to use to manage a transaction around the storage and publication of
events. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)
Sets the
WaitStrategy which is used to make dependent threads wait for tasks to be completed. |
Constructor and Description |
---|
DisruptorCommandBus(DisruptorCommandBus.Builder builder)
Instantiate a
DisruptorCommandBus based on the fields contained in the DisruptorCommandBus.Builder . |
Copyright © 2010–2019. All rights reserved.