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<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. |
Constructor and Description |
---|
DisruptorCommandBus(EventStore eventStore,
EventBus eventBus,
DisruptorConfiguration configuration)
Initialize the DisruptorCommandBus with given resources and settings.
|
Copyright © 2010-2014. All Rights Reserved.