org.axonframework.commandhandling.disruptor

Class CommandHandlerInvoker

java.lang.Object

org.axonframework.commandhandling.disruptor.CommandHandlerInvoker

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<CommandHandlingEntry>, com.lmax.disruptor.LifecycleAware

public class CommandHandlerInvoker
extends Object
implements com.lmax.disruptor.EventHandler<CommandHandlingEntry>, com.lmax.disruptor.LifecycleAware

Component of the DisruptorCommandBus that invokes the command handler. The execution is done within a Unit Of Work. If an aggregate has been pre-loaded, it is set to the ThreadLocal.

Since:

2.0

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
CommandHandlerInvoker(Cache cache, int segmentId) Create an aggregate invoker instance for the given segment and cache.

Method Summary

Modifier and Type	Method and Description
<T> Repository<T>	createRepository(EventStore eventStore, AggregateFactory<T> aggregateFactory, SnapshotTriggerDefinition snapshotTriggerDefinition, ParameterResolverFactory parameterResolverFactory) Create a repository instance for an aggregate created by the given aggregateFactory.
static <T> org.axonframework.commandhandling.disruptor.CommandHandlerInvoker.DisruptorRepository<T>	getRepository(Class<?> type) Returns the Repository instance for Aggregate with given typeIdentifier used by the CommandHandlerInvoker that is running on the current thread.
void	onEvent(CommandHandlingEntry entry, long sequence, boolean endOfBatch)
void	onShutdown()
void	onStart()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommandHandlerInvoker

public CommandHandlerInvoker(Cache cache,
                             int segmentId)

Create an aggregate invoker instance for the given segment and cache.

Parameters:

cache - The cache temporarily storing aggregate instances

segmentId - The id of the segment this invoker should handle

Method Detail

getRepository

public static <T> org.axonframework.commandhandling.disruptor.CommandHandlerInvoker.DisruptorRepository<T> getRepository(Class<?> type)

Returns the Repository instance for Aggregate with given typeIdentifier used by the CommandHandlerInvoker that is running on the current thread.

Calling this method from any other thread will return null.

Type Parameters:

T - The type of aggregate

Parameters:

type - The type of aggregate

Returns:

the repository instance for aggregate of given type

onEvent

public void onEvent(CommandHandlingEntry entry,
                    long sequence,
                    boolean endOfBatch)
             throws Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<CommandHandlingEntry>

Throws:

Exception

createRepository

public <T> Repository<T> createRepository(EventStore eventStore,
                                          AggregateFactory<T> aggregateFactory,
                                          SnapshotTriggerDefinition snapshotTriggerDefinition,
                                          ParameterResolverFactory parameterResolverFactory)

Create a repository instance for an aggregate created by the given aggregateFactory. The returning repository must be safe to use by this invoker instance.

Type Parameters:

T - The type of aggregate created by the factory

Parameters:

eventStore - The events store to load and publish events

aggregateFactory - The factory creating aggregate instances

snapshotTriggerDefinition - The trigger definition for snapshots

parameterResolverFactory - The factory used to resolve parameters on command handler methods

Returns:

A Repository instance for the given aggregate

onStart

public void onStart()

Specified by:

onStart in interface com.lmax.disruptor.LifecycleAware

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface com.lmax.disruptor.LifecycleAware