-
DisruptorCommandBus.Builder.bufferSize(int bufferSize)
Sets the buffer size to use.
DisruptorCommandBus.Builder.cache(org.axonframework.common.caching.Cache cache)
Sets the Cache in which loaded aggregates will be stored.
DisruptorCommandBus.Builder.commandTargetResolver(org.axonframework.modelling.command.CommandTargetResolver commandTargetResolver)
Sets the CommandTargetResolver that must be used to indicate which Aggregate instance will be invoked
by an incoming command.
Sets the cooling down period in milliseconds.
DisruptorCommandBus.Builder.dispatchInterceptors(List<org.axonframework.messaging.MessageDispatchInterceptor<org.axonframework.commandhandling.CommandMessage<?>>> dispatchInterceptors)
Configures
MessageDispatchInterceptor of generic type
CommandMessage to use with the
DisruptorCommandBus when commands are dispatched.
DisruptorCommandBus.Builder.duplicateCommandHandlerResolver(org.axonframework.commandhandling.DuplicateCommandHandlerResolver duplicateCommandHandlerResolver)
Sets the DuplicateCommandHandlerResolver used to resolves the road to take when a duplicate command
handler is subscribed.
DisruptorCommandBus.Builder.invokerInterceptors(List<org.axonframework.messaging.MessageHandlerInterceptor<? super org.axonframework.commandhandling.CommandMessage<?>>> invokerInterceptors)
Set the
MessageHandlerInterceptor of generic type
CommandMessage to use with the
DisruptorCommandBus during in the invocation thread.
Sets the number of Threads that should be used to invoke the Command Handlers.
DisruptorCommandBus.Builder.messageMonitor(org.axonframework.monitoring.MessageMonitor<? super org.axonframework.commandhandling.CommandMessage<?>> messageMonitor)
Sets the MessageMonitor of generic type CommandMessage used the to monitor the command bus.
DisruptorCommandBus.Builder.producerType(com.lmax.disruptor.dsl.ProducerType producerType)
Sets the ProducerType to use by the Disruptor.
DisruptorCommandBus.Builder.publisherInterceptors(List<org.axonframework.messaging.MessageHandlerInterceptor<org.axonframework.commandhandling.CommandMessage<?>>> publisherInterceptors)
Configures the
MessageHandlerInterceptor of generic type
CommandMessage to use with the
DisruptorCommandBus during the publication of changes.
Sets the number of Threads that should be used to store and publish the generated Events.
Set the indicator specifying whether commands that failed because they were executed against potentially
corrupted aggregate state should be automatically rescheduled.
DisruptorCommandBus.Builder.rollbackConfiguration(org.axonframework.messaging.unitofwork.RollbackConfiguration rollbackConfiguration)
Sets the RollbackConfiguration which allows you to specify when a UnitOfWork should be rolled
back.
DisruptorCommandBus.Builder.transactionManager(org.axonframework.common.transaction.TransactionManager transactionManager)
Sets the TransactionManager to use to manage a transaction around the storage and publication of
events.
DisruptorCommandBus.Builder.waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)
Sets the WaitStrategy which is used to make dependent threads wait for tasks to be completed.