Package | Description |
---|---|
org.axonframework.commandhandling.disruptor |
Modifier and Type | Method and Description |
---|---|
DisruptorConfiguration |
DisruptorConfiguration.setBufferSize(int newBufferSize)
Sets the buffer size to use.
|
DisruptorConfiguration |
DisruptorConfiguration.setCache(Cache cache)
Sets the cache in which loaded aggregates will be stored.
|
DisruptorConfiguration |
DisruptorConfiguration.setCommandTargetResolver(CommandTargetResolver newCommandTargetResolver)
Sets the CommandTargetResolver that must be used to indicate which Aggregate instance will be invoked by an
incoming command.
|
DisruptorConfiguration |
DisruptorConfiguration.setCoolingDownPeriod(long coolingDownPeriod)
Sets the cooling down period in milliseconds.
|
DisruptorConfiguration |
DisruptorConfiguration.setDispatchInterceptors(List<MessageDispatchInterceptor<CommandMessage<?>>> dispatchInterceptors)
Configures the CommandDispatchInterceptor to use with the DisruptorCommandBus when commands are dispatched.
|
DisruptorConfiguration |
DisruptorConfiguration.setExecutor(Executor executor)
Sets the Executor that provides the processing resources (Threads) for the components of the DisruptorCommandBus.
|
DisruptorConfiguration |
DisruptorConfiguration.setInvokerInterceptors(List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors)
Configures the CommandHandlerInterceptors to use with the DisruptorCommandBus during in the invocation thread.
|
DisruptorConfiguration |
DisruptorConfiguration.setInvokerThreadCount(int count)
Sets the number of Threads that should be used to invoke the Command Handlers.
|
DisruptorConfiguration |
DisruptorConfiguration.setMessageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the message monitor to use.
|
DisruptorConfiguration |
DisruptorConfiguration.setProducerType(com.lmax.disruptor.dsl.ProducerType producerType)
Sets the producer type to use.
|
DisruptorConfiguration |
DisruptorConfiguration.setPublisherInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> publisherInterceptors)
Configures the CommandHandlerInterceptors to use with the DisruptorCommandBus during the publication of changes.
|
DisruptorConfiguration |
DisruptorConfiguration.setPublisherThreadCount(int count)
Sets the number of Threads that should be used to store and publish the generated Events.
|
DisruptorConfiguration |
DisruptorConfiguration.setRescheduleCommandsOnCorruptState(boolean rescheduleCommandsOnCorruptState)
Indicates whether commands that failed because they were executed against potentially corrupted aggregate state
should be automatically rescheduled.
|
DisruptorConfiguration |
DisruptorConfiguration.setRollbackConfiguration(RollbackConfiguration rollbackConfiguration)
Sets the rollback configuration for the DisruptorCommandBus to use.
|
DisruptorConfiguration |
DisruptorConfiguration.setSerializer(Serializer newSerializer)
Returns the serializer to perform pre-serialization with, or
null if no pre-serialization should be
done. |
DisruptorConfiguration |
DisruptorConfiguration.setTransactionManager(TransactionManager newTransactionManager)
Sets the transaction manager to use to manage a transaction around the storage and publication of events.
|
DisruptorConfiguration |
DisruptorConfiguration.setWaitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)
Sets the
WaitStrategy , which used to make dependent threads wait for tasks to be completed. |
Constructor and Description |
---|
DisruptorCommandBus(DisruptorConfiguration configuration)
Initialize the DisruptorCommandBus with given resources and settings.
|
DisruptorCommandBus(EventStore eventStore,
DisruptorConfiguration configuration)
Deprecated.
Use
instead |
Copyright © 2010–2017. All rights reserved.