| Modifier and Type | Class and Description |
|---|---|
class |
CurrentUnitOfWorkParameterResolverFactory
ParameterResolverFactory that add support for the UnitOfWork parameter type in annotated handlers.
|
class |
InterceptorChainParameterResolverFactory
Parameter resolver factory that adds support for resolving current
InterceptorChain. |
| Constructor and Description |
|---|
AggregateAnnotationCommandHandler(Class<T> aggregateType,
Repository<T> repository,
CommandTargetResolver commandTargetResolver,
ParameterResolverFactory parameterResolverFactory)
Initializes an AnnotationCommandHandler based on the annotations on given
aggregateType, using the
given repository to add and load aggregate instances and the given
parameterResolverFactory. |
AggregateAnnotationCommandHandler(Class<T> aggregateType,
Repository<T> repository,
CommandTargetResolver commandTargetResolver,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes an AnnotationCommandHandler based on the annotations on given
aggregateType, using the given
repository to add and load aggregate instances, the given parameterResolverFactory to resolve
parameters which are required by handlers and the given handlerDefinition used to create handlers. |
AnnotationCommandHandlerAdapter(Object annotatedCommandHandler,
ParameterResolverFactory parameterResolverFactory)
Wraps the given
annotatedCommandHandler, allowing it to be subscribed to a Command Bus. |
AnnotationCommandHandlerAdapter(Object annotatedCommandHandler,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Wraps the given
annotatedCommandHandler, allowing it to be subscribed to a Command Bus. |
| Modifier and Type | Class and Description |
|---|---|
class |
ConflictResolution
ParameterResolverFactory that add support for the ConflictResolver parameter type in annotated handlers.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Repository<T> |
DisruptorCommandBus.createRepository(AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory)
|
<T> Repository<T> |
DisruptorCommandBus.createRepository(AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory)
|
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory)
Creates a repository instance for an Event Sourced aggregate that is created by the given
aggregateFactory and sourced from given eventStore. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate that is created by the given
aggregateFactory and sourced from given eventStore. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory)
Creates a repository instance for an Event Sourced aggregate, sourced from given
eventStore, that is
created by the given aggregateFactory. |
<T> Repository<T> |
CommandHandlerInvoker.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory)
Create a repository instance for an aggregate created by the given
aggregateFactory. |
<T> Repository<T> |
DisruptorCommandBus.createRepository(EventStore eventStore,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Creates a repository instance for an Event Sourced aggregate, sourced from given
eventStore, that is
created by the given aggregateFactory. |
<T> Repository<T> |
CommandHandlerInvoker.createRepository(EventStore eventStore,
RepositoryProvider repositoryProvider,
AggregateFactory<T> aggregateFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Create a repository instance for an aggregate created by the given
aggregateFactory. |
| Constructor and Description |
|---|
AbstractRepository(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Initializes a repository that stores aggregate of the given
aggregateType. |
AbstractRepository(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes a repository that stores aggregate of the given
aggregateType. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an
Identifier Object. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
ParameterResolverFactory parameterResolverFactory)
Initialize a repository for storing aggregates of the given
aggregateType. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Function<String,?> identifierConverter)
Initialize a repository for storing aggregates of the given
aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an
Identifier Object. |
GenericJpaRepository(EntityManagerProvider entityManagerProvider,
Class<T> aggregateType,
EventBus eventBus,
RepositoryProvider repositoryProvider,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize a repository for storing aggregates of the given
aggregateType. |
LockingRepository(Class<T> aggregateType,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory)
Initialize the repository with the given
lockFactory and parameterResolverFactory. |
LockingRepository(Class<T> aggregateType,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize the repository with the given
lockFactory, parameterResolverFactory and handlerDefinition. |
LockingRepository(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Initialize a repository with a pessimistic locking strategy and a parameter resolver factory.
|
LockingRepository(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initialize a repository with a pessimistic locking strategy and a parameter resolver factory.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> AggregateModel<T> |
ModelInspector.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Deprecated.
Create an inspector for given
aggregateType that uses given parameterResolverFactory to resolve
method parameters. |
static <T> AggregateModel<T> |
AnnotatedAggregateMetaModelFactory.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory)
Shorthand to create a factory instance and inspect the model for the given
aggregateType, using given
parameterResolverFactory to resolve parameter values for annotated handlers. |
static <T> AggregateModel<T> |
AnnotatedAggregateMetaModelFactory.inspectAggregate(Class<T> aggregateType,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Shorthand to create a factory instance and inspect the model for the given
aggregateType, using given
parameterResolverFactory to resolve parameter values for annotated handlers and handlerDefinition
to create concrete handlers. |
| Constructor and Description |
|---|
AnnotatedAggregateMetaModelFactory(ParameterResolverFactory parameterResolverFactory)
Initializes an instance which uses the given
parameterResolverFactory to detect parameters for
annotated handlers. |
AnnotatedAggregateMetaModelFactory(ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes an instance which uses the given
parameterResolverFactory to detect parameters for
annotated handlers and handlerDefinition to create concrete handlers. |
| Modifier and Type | Class and Description |
|---|---|
class |
ConfigurationParameterResolverFactory
ParameterResolverFactory implementation that resolves parameters from available components in the Configuration
instance it was configured with.
|
| Modifier and Type | Method and Description |
|---|---|
protected ParameterResolverFactory |
DefaultConfigurer.defaultParameterResolverFactory(Configuration config)
Provides the default ParameterResolverFactory.
|
default ParameterResolverFactory |
Configuration.parameterResolverFactory()
Returns the Parameter Resolver Factory defined in this Configuration
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConcludesBatchParameterResolverFactory
Paramater resolver factory for boolean event handler parameters annotated with
ConcludesBatch. |
class |
TimestampParameterResolverFactory
|
| Constructor and Description |
|---|
AnnotationEventListenerAdapter(Object annotatedEventListener,
ParameterResolverFactory parameterResolverFactory)
Wraps the given
annotatedEventListener, allowing it to be subscribed to an Event Bus. |
AnnotationEventListenerAdapter(Object annotatedEventListener,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Wraps the given
annotatedEventListener, allowing it to be subscribed to an Event Bus. |
SimpleEventHandlerInvoker(List<?> eventListeners,
ParameterResolverFactory parameterResolverFactory,
ListenerInvocationErrorHandler listenerInvocationErrorHandler)
Initializes a
SimpleEventHandlerInvoker containing the given list of eventListeners. |
SimpleEventHandlerInvoker(List<?> eventListeners,
ParameterResolverFactory parameterResolverFactory,
ListenerInvocationErrorHandler listenerInvocationErrorHandler,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Initializes a
SimpleEventHandlerInvoker containing the given list of eventListeners. |
| Modifier and Type | Class and Description |
|---|---|
class |
ReplayParameterResolverFactory
An implementation of the
ParameterResolverFactory which resolves the
ReplayStatus parameter. |
| Constructor and Description |
|---|
AnnotatedSagaManager(Class<T> sagaType,
SagaRepository<T> sagaRepository,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
ListenerInvocationErrorHandler listenerInvocationErrorHandler)
Initialize the AnnotatedSagaManager using given
repository to load sagas. |
AnnotatedSagaManager(Class<T> sagaType,
SagaRepository<T> sagaRepository,
ParameterResolverFactory parameterResolverFactory,
ListenerInvocationErrorHandler listenerInvocationErrorHandler)
Initialize the AnnotatedSagaManager using given
repository to load sagas. |
| Constructor and Description |
|---|
AnnotationSagaMetaModelFactory(ParameterResolverFactory parameterResolverFactory)
Initializes a
AnnotationSagaMetaModelFactory with given parameterResolverFactory and ClasspathHandlerDefinition. |
AnnotationSagaMetaModelFactory(ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes a
AnnotationSagaMetaModelFactory with given parameterResolverFactory and given handlerDefinition. |
DefaultSagaMetaModelFactory(ParameterResolverFactory parameterResolverFactory)
Deprecated.
Initializes a
DefaultSagaMetaModelFactory with given parameterResolverFactory. |
| Constructor and Description |
|---|
AnnotatedSagaRepository(Class<T> sagaType,
SagaStore<? super T> sagaStore,
ResourceInjector resourceInjector,
ParameterResolverFactory parameterResolverFactory)
Initializes an AnnotatedSagaRepository for given
sagaType that stores sagas in the given sagaStore. |
AnnotatedSagaRepository(Class<T> sagaType,
SagaStore<? super T> sagaStore,
ResourceInjector resourceInjector,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes an AnnotatedSagaRepository for given
sagaType that stores sagas in the given sagaStore. |
| Modifier and Type | Class and Description |
|---|---|
class |
SequenceNumberParameterResolverFactory
An extension of the AbstractAnnotatedParameterResolverFactory that accepts parameters of a
Long type
annotated with the SequenceNumber annotation and assigns the sequenceNumber of the DomainEventMessage. |
| Constructor and Description |
|---|
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory)
Initializes a snapshotter using the given
parameterResolverFactory. |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager transactionManager)
Initializes a snapshotter that stores snapshots using the given
executor. |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager transactionManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter that stores snapshots using the given
executor. |
AggregateSnapshotter(EventStore eventStore,
List<AggregateFactory<?>> aggregateFactories,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the given
parameterResolverFactory. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
CachingEventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
Cache cache,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with a the given
aggregateFactory and a pessimistic locking strategy. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initialize a repository with the given locking strategy and parameter resolver factory.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
LockFactory lockFactory,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initialize a repository with the given locking strategy and parameter resolver factory.
|
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
SnapshotTriggerDefinition snapshotTriggerDefinition,
RepositoryProvider repositoryProvider)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
EventSourcingRepository(AggregateFactory<T> aggregateFactory,
EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
SnapshotTriggerDefinition snapshotTriggerDefinition)
Initializes a repository with the default locking strategy, using the given
aggregateFactory to
create new aggregate instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
TrackingTokenParameterResolverFactory
Implementation of a
ParameterResolverFactory that resolves the TrackingToken of an event message
if that message is a TrackedEventMessage. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAnnotatedParameterResolverFactory<A extends Annotation,P>
ParameterResolverFactory that will supply a parameter resolver when a matching parameter annotation is paired
with a suitable type of parameter.
|
class |
DefaultParameterResolverFactory
Factory for the default parameter resolvers.
|
class |
MessageIdentifierParameterResolverFactory
An extension of the AbstractAnnotatedParameterResolverFactory that accepts
parameters of a
String type that are annotated with the MessageIdentifier
annotation and assigns the identifier of the Message. |
class |
MultiParameterResolverFactory
ParameterResolverFactory instance that delegates to multiple other instances, in the order provided.
|
class |
SimpleResourceParameterResolverFactory
A
ParameterResolverFactory implementation for simple resource injections. |
| Modifier and Type | Method and Description |
|---|---|
static ParameterResolverFactory |
ClasspathParameterResolverFactory.forClass(Class<?> clazz)
Creates an instance for the given
clazz. |
static ParameterResolverFactory |
ClasspathParameterResolverFactory.forClassLoader(ClassLoader classLoader)
Creates an instance using the given
classLoader. |
| Modifier and Type | Method and Description |
|---|---|
List<ParameterResolverFactory> |
MultiParameterResolverFactory.getDelegates()
Returns the delegates of this instance, in the order they are evaluated to resolve parameters.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Optional<MessageHandlingMember<T>> |
MultiHandlerDefinition.createHandler(Class<T> declaringType,
Executable executable,
ParameterResolverFactory parameterResolverFactory) |
<T> Optional<MessageHandlingMember<T>> |
HandlerDefinition.createHandler(Class<T> declaringType,
Executable executable,
ParameterResolverFactory parameterResolverFactory)
Create a
MessageHandlingMember for the given executable method. |
<T> Optional<MessageHandlingMember<T>> |
AnnotatedMessageHandlingMemberDefinition.createHandler(Class<T> declaringType,
Executable executable,
ParameterResolverFactory parameterResolverFactory) |
static <T> AnnotatedHandlerInspector<T> |
AnnotatedHandlerInspector.inspectType(Class<? extends T> handlerType,
ParameterResolverFactory parameterResolverFactory)
Create an inspector for given
handlerType that uses given parameterResolverFactory to resolve
method parameters. |
static <T> AnnotatedHandlerInspector<T> |
AnnotatedHandlerInspector.inspectType(Class<? extends T> handlerType,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Create an inspector for given
handlerType that uses given parameterResolverFactory to resolve
method parameters and given handlerDefinition to create handlers. |
static MultiParameterResolverFactory |
MultiParameterResolverFactory.ordered(ParameterResolverFactory... delegates)
Creates a MultiParameterResolverFactory instance with the given
delegates, which are automatically
ordered based on the @Priority annotation on their respective classes. |
| Modifier and Type | Method and Description |
|---|---|
static MultiParameterResolverFactory |
MultiParameterResolverFactory.ordered(List<ParameterResolverFactory> delegates)
Creates a MultiParameterResolverFactory instance with the given
delegates, which are automatically
ordered based on the @Priority annotation on their respective classes. |
| Constructor and Description |
|---|
AnnotatedMessageHandlingMember(Executable executable,
Class<? extends Message> messageType,
Class<?> explicitPayloadType,
ParameterResolverFactory parameterResolverFactory)
Initializes a new instance that will invoke the given
executable (method) on a target to handle a message
of the given messageType. |
MultiParameterResolverFactory(ParameterResolverFactory... delegates)
Initializes an instance that delegates to the given
delegates, in the order provided. |
| Constructor and Description |
|---|
MultiParameterResolverFactory(List<ParameterResolverFactory> delegates)
Initializes an instance that delegates to the given
delegates, in the order provided. |
| Constructor and Description |
|---|
AnnotationQueryHandlerAdapter(T target,
ParameterResolverFactory parameterResolverFactory)
Initializes the adapter, forwarding call to the given
target, resolving parameters using the given
parameterResolverFactory. |
AnnotationQueryHandlerAdapter(T target,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Initializes the adapter, forwarding call to the given
target, resolving parameters using the given
parameterResolverFactory and creating handlers using handlerDefinition. |
| Modifier and Type | Method and Description |
|---|---|
ParameterResolverFactory |
ApplicationContextLookupParameterResolverFactory.getObject() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract T |
AbstractAnnotationHandlerBeanPostProcessor.initializeAdapterFor(Object bean,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition)
Create an AnnotationEventListenerAdapter instance of the given
bean. |
void |
AbstractAnnotationHandlerBeanPostProcessor.setParameterResolverFactory(ParameterResolverFactory parameterResolverFactory)
Sets the ParameterResolverFactory to create the Parameter Resolvers with that provide the parameter values for
the handler methods.
|
| Constructor and Description |
|---|
ApplicationContextLookupParameterResolverFactory(List<ParameterResolverFactory> defaultFactories)
Creates an instance, using the given
defaultFactories. |
| Modifier and Type | Class and Description |
|---|---|
class |
SpringBeanParameterResolverFactory
ParameterResolverFactory implementation that resolves parameters in the Spring Application Context.
|
| Modifier and Type | Method and Description |
|---|---|
ParameterResolverFactory |
SpringParameterResolverFactoryBean.getObject() |
| Modifier and Type | Method and Description |
|---|---|
protected AnnotationQueryHandlerAdapter |
AnnotationQueryHandlerBeanPostProcessor.initializeAdapterFor(Object o,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition) |
protected AnnotationCommandHandlerAdapter |
AnnotationCommandHandlerBeanPostProcessor.initializeAdapterFor(Object bean,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition) |
| Modifier and Type | Method and Description |
|---|---|
void |
SpringParameterResolverFactoryBean.setAdditionalFactories(List<ParameterResolverFactory> additionalFactories)
Defines any additional parameter resolver factories that need to be used to resolve parameters.
|
| Constructor and Description |
|---|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
Executor executor,
TransactionManager txManager)
Initializes a snapshotter.
|
SpringAggregateSnapshotter(EventStore eventStore,
ParameterResolverFactory parameterResolverFactory,
HandlerDefinition handlerDefinition,
Executor executor,
TransactionManager txManager,
RepositoryProvider repositoryProvider)
Initializes a snapshotter using the ParameterResolverFactory instances available on the classpath.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FixtureResourceParameterResolverFactory
ParameterResolverFactory implementation for use in test cases that prevent that all declared resources on message
handlers need to be configured.
|
Copyright © 2010–2018. All rights reserved.