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.