Uses of Class
org.axonframework.disruptor.commandhandling.DisruptorCommandBus.Builder
Packages that use DisruptorCommandBus.Builder
-
Uses of DisruptorCommandBus.Builder in org.axonframework.disruptor.commandhandling
Methods in org.axonframework.disruptor.commandhandling that return DisruptorCommandBus.BuilderModifier and TypeMethodDescriptionDisruptorCommandBus.Builder.bufferSize(int bufferSize) Sets the buffer size to use.static DisruptorCommandBus.BuilderDisruptorCommandBus.builder()Instantiate a Builder to be able to create aDisruptorCommandBus.Sets theCachein which loaded aggregates will be stored.DisruptorCommandBus.Builder.commandTargetResolver(CommandTargetResolver commandTargetResolver) Sets theCommandTargetResolverthat must be used to indicate which Aggregate instance will be invoked by an incoming command.DisruptorCommandBus.Builder.coolingDownPeriod(long coolingDownPeriod) Sets the cooling down period in milliseconds.DisruptorCommandBus.Builder.defaultCommandCallback(CommandCallback<Object, Object> defaultCommandCallback) Sets the callback to use when commands are dispatched in a "fire and forget" method, such asDisruptorCommandBus.dispatch(CommandMessage).DisruptorCommandBus.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<CommandMessage<?>>> dispatchInterceptors) ConfiguresMessageDispatchInterceptorof generic typeCommandMessageto use with theDisruptorCommandBuswhen commands are dispatched.DisruptorCommandBus.Builder.duplicateCommandHandlerResolver(DuplicateCommandHandlerResolver duplicateCommandHandlerResolver) Sets theDuplicateCommandHandlerResolverused to resolves the road to take when a duplicate command handler is subscribed.Sets theExecutorthat provides the processing resources (Threads) for the components of theDisruptorCommandBus.DisruptorCommandBus.Builder.invokerInterceptors(List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors) Set theMessageHandlerInterceptorof generic typeCommandMessageto use with theDisruptorCommandBusduring in the invocation thread.DisruptorCommandBus.Builder.invokerThreadCount(int invokerThreadCount) Sets the number of Threads that should be used to invoke the Command Handlers.DisruptorCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) Sets theMessageMonitorof generic typeCommandMessageused the to monitor the command bus.DisruptorCommandBus.Builder.producerType(com.lmax.disruptor.dsl.ProducerType producerType) Sets theProducerTypeto use by theDisruptor.DisruptorCommandBus.Builder.publisherInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> publisherInterceptors) Configures theMessageHandlerInterceptorof generic typeCommandMessageto use with theDisruptorCommandBusduring the publication of changes.DisruptorCommandBus.Builder.publisherThreadCount(int publisherThreadCount) Sets the number of Threads that should be used to store and publish the generated Events.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.rollbackConfiguration(RollbackConfiguration rollbackConfiguration) Sets theRollbackConfigurationwhich allows you to specify when aUnitOfWorkshould be rolled back.DisruptorCommandBus.Builder.transactionManager(TransactionManager transactionManager) Sets theTransactionManagerto use to manage a transaction around the storage and publication of events.DisruptorCommandBus.Builder.waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy) Sets theWaitStrategywhich is used to make dependent threads wait for tasks to be completed.Constructors in org.axonframework.disruptor.commandhandling with parameters of type DisruptorCommandBus.BuilderModifierConstructorDescriptionprotectedInstantiate aDisruptorCommandBusbased on the fields contained in theDisruptorCommandBus.Builder.