Uses of Class
org.axonframework.commandhandling.disruptor.DisruptorConfiguration

Packages that use DisruptorConfiguration

org.axonframework.commandhandling.disruptor

Uses of DisruptorConfiguration in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return DisruptorConfiguration

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<CommandDispatchInterceptor> 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<CommandHandlerInterceptor> 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.setProducerType(com.lmax.disruptor.dsl.ProducerType producerType) Sets the producer type to use.
DisruptorConfiguration	DisruptorConfiguration.setPublisherInterceptors(List<CommandHandlerInterceptor> 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.setSerializedRepresentation(Class<?> newSerializedRepresentation) Sets the type of data the serialized object should be represented in.
DisruptorConfiguration	DisruptorConfiguration.setSerializer(Serializer newSerializer) Returns the serializer to perform pre-serialization with, or null if no pre-serialization should be done.
DisruptorConfiguration	DisruptorConfiguration.setSerializerThreadCount(int newSerializerThreadCount) Sets the number of threads that should perform the pre-serialization step.
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.

Constructors in org.axonframework.commandhandling.disruptor with parameters of type DisruptorConfiguration

DisruptorCommandBus(EventStore eventStore, EventBus eventBus, DisruptorConfiguration configuration)
Initialize the DisruptorCommandBus with given resources and settings.