|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
EventSourcingHandler
annotation (and EventHandler
for backwards compatibility).EventHandler
annotation.annotationType
.
declaredParameterType
annotated with the given annotationType
.
interface
that delegates incoming events to @SagaEventHandler
annotated methods.Cluster
implementation that keeps track of Cluster members (EventListeners
).name
.
name
, using given comparator
to order the listeners
in the cluster.
commandBus
, retryScheduler
and
commandDispatchInterceptors
.
event
.
event
.
payloadType
, declared in the given
declaringClass
and using the given parameterValueResolvers
.
mongo
instance and a database with default
name "axonframework".
mongo
instance and the database with given
databaseName
.
Repository
that takes care of the dispatching of events when an aggregate is
persisted.aggregateType
.
unresolvedRoutingKeyPolicy
prescribing what happens when a
routing key cannot be resolved.
AbstractSagaManager.AbstractSagaManager(SagaRepository, SagaFactory, Class[])
and register using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
sagaRepository
.
Snapshotter
that uses a task executor to
creates snapshots.upcasters
and a ChainingConverterFactory
to
convert between content types.
converterFactory
and upcasters
.
charset
and xStream
instance.
charset
and xStream
instance.
charset
, xStream
instance,
revisionResolver
and converterFactory
.
field
should be accepted for processing, or skipped/ignored.
aggregate
to the repository.
aggregate
to the repository.
associationValue
, if it has not been previously added.
associationValue
and sagaIdentifier
.
AssociationValues.commit()
.
newDateTime
and returns all events scheduled for publication until that
time.
duration
and returns all events scheduled for publication until that
time.
CommandHandler
annotations on an aggregate.aggregateType
, using the
given repository
to add and load aggregate instances.
aggregateType
, using the
given repository
to add and load aggregate instances and the default ParameterResolverFactory.
aggregateType
, using the
given repository
to add and load aggregate instances and the given
parameterResolverFactory
.
AggregateAnnotationCommandHandler.AggregateAnnotationCommandHandler(Class, org.axonframework.repository.Repository)
and subscribe the adapter to the command bus using
CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler)
. Alternatively, use
AggregateAnnotationCommandHandler.subscribe(Class, org.axonframework.repository.Repository, org.axonframework.commandhandling.CommandBus)
.
AggregateAnnotationCommandHandler.AggregateAnnotationCommandHandler(Class, org.axonframework.repository.Repository,
org.axonframework.commandhandling.CommandTargetResolver)
and subscribe the handler to the command
bus using CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler)
. Alternatively, use
AggregateAnnotationCommandHandler.subscribe(Class, org.axonframework.repository.Repository, org.axonframework.commandhandling.CommandBus,
org.axonframework.commandhandling.CommandTargetResolver)
.
AggregateIdentifier
and EventSourcedMember
.aggregateIdentifier
, given explanatory message
and cause
.
annotationType
is used to annotate the
Event Handler methods.
AggregateNotFoundException
that indicates that historic
information of an aggregate was found, but the aggregate has been deleted.aggregateIdentifier
and
given message
.
aggregateIdentifier
and
a default message
.
message
aggregateIdentifier
and given message
.
aggregateIdentifier
and
with the given message
and cause
.
aggregateIdentifier
and given explanatory
message
.
aggregateIdentifier
, given explanatory message
and cause
.
body
and routingKey
, which is not mandatory and
non-immediate and has no additional properties.
this
and given criteria
must match.
criteria1
and criteria2
to be
true
.
criteria1
and criteria2
to be
true
.
metaData
.
metaData
.
metaData
.
metaData
.
metaData
.
null
or void
.
event
has been published in the past.
AnnotatedSagaManager.AnnotatedSagaManager(org.axonframework.saga.SagaRepository,
Class[])
instead and register this instance using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
AnnotatedSagaManager.AnnotatedSagaManager(org.axonframework.saga.SagaRepository,
org.axonframework.saga.SagaFactory, Class[])
instead and register this instance using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
repository
to load sagas and supporting given
annotated sagaClasses
.
repository
to load sagas and supporting given
annotated sagaClasses
.
sagaType
.
cluster
for Event Listeners that are
annotated with the given annotationType
.
cluster
for Event Listeners that are
annotated with the given annotationType
.
@CommandHandler
annotated bean into a CommandHandler
implementation.AnnotationCommandHandlerAdapter.AnnotationCommandHandlerAdapter(Object)
and subscribe the handler to the command bus
using CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler)
.
annotatedCommandHandler
, allowing it to be subscribed to a Command Bus.
annotatedCommandHandler
, allowing it to be subscribed to a Command Bus.
CommandHandler
annotated methods.@Configuration
that will automatically
subscribe @CommandHandler
and @EventHandler
annotated beans with the CommandBus and
EventBus, respectively.EventHandler
annotated methods into an EventListener
.annotatedEventListener
, allowing it to be subscribed to an Event Bus.
annotatedEventListener
, allowing it to be subscribed to an Event Bus.
AnnotationEventListenerAdapter.AnnotationEventListenerAdapter(Object)
and subscribe the listener to the event bus
using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
EventHandler
annotated methods.@Revision
annotation.TargetAggregateIdentifier
annotation on the command message's payload.unresolvedRoutingKeyPolicy
when an incoming
command does not define an AggregateIdentifier to base the routing key on.
unresolvedRoutingKeyPolicy
when an incoming command does not define an AggregateIdentifier to base
the routing key on.
stream
to the event store.
stream
to the event store.
stream
to the event store.
stream
to the event store.
snapshotEvent
to the snapshot event log for the given type type
.
snapshotEvent
to the snapshot event log for the given type type
.
snapshotEvent
to the snapshot event log for the given type type
.
snapshotEvent
to the snapshot event log for the given type type
.
defaultFactories
.
metaData
.
expected
amount of active sagas.
associationKey
and
associationValue
.
matcher
has been dispatched on the command bus.
associationKey
and
associationValue
.
expected
events have been published.
matcher
.
matcher
is scheduled for publication after the given
duration
.
matcher
is scheduled for publication at the given
scheduledTime
.
event
.
key
and value
.
sagaIdentifier
and
associationValue
.
Association Values
for a single Saga
instance.AsyncAnnotatedSagaManager.AsyncAnnotatedSagaManager(Class[])
and register with the event bus using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
sagaTypes
.
sagaTypes
.
executor
,
transactionManager
and sequencingPolicy
.
executor
and
sequencingPolicy
.
executor
,
transactionManager
and sequencingPolicy
.
executor
,
unitOfWorkFactory
and sequencingPolicy
.
executor
,
unitOfWorkFactory
and sequencingPolicy
.
executor
.
unitOfWork
.
resource
to this Unit of Work under the given name
.
resource
to this Unit of Work under the given name
.
command
.
mongo
instance and a database with default
name "axonframework".
mongo
instance and the database with given
databaseName
.
mongo
instance and the database with given
databaseName
.
beanTypes
.
beanTypes
,
reverting to the given defaultBean
if no candidates are found.
resources
.
detailMessage
.
message
.
message
and cause
.
message
.
message
and cause
.
message
.
message
and cause
.
groupName
with
default priority.
group
with default
priority.
group
with given
priority
.
message
.
message
and cause
.
Validation.buildDefaultValidatorFactory()
).
command
to be rescheduled on the given
ringBuffer
if it failed due to a corrupt state.
jobKey
at (or around) the given
triggerDateTime
.
objectMapper
to parse the binary contents
aggregateFactory
and a pessimistic locking strategy.
aggregateFactory
and a pessimistic locking strategy.
delegate
, storing associations in the given
associationsCache
and Saga instances in the given sagaCache
.
sourceType
to the
given targetType
using a chain formed with given candidates
.
false
, since command execution cannot be cancelled.
sourceContentType
into
targetContentType
, using the given converters
.
message
.
message
and cause
.
expectedRepresentation
.
type
.
delegates
to form a chain of converters.
mappings
.
prefix
will be
mapped to the given cluster
.
mappings
.
mappings
.
unitOfWork
.
connection
, which was wrapped by the ConnectionWrapperFactory.
closeable
if it implements the Closeable
interface.
resultSet
, if possible.
statement
, if possible.
connection
, if possible.
Closeable
, while suppressing any IOExceptions it will
generate.
ClusteringEventBus
.EventBus
implementation that supports clustering of Event Listeners.ClusteringEventBus
with a SimpleEventBusTerminal
and a DefaultClusterSelector
.
ClusteringEventBus
with the given terminal
and a DefaultClusterSelector
.
ClusteringEventBus
with the given clusterSelector
and a SimpleEventBusTerminal
, which dispatches all events to all local clusters synchronously.
ClusteringEventBus
with the given clusterSelector
and a
terminal
.
initialCluster
that uses given
serializer
to deserialize the message's contents into an EventMessage.
property
value to be present in the given
expression
to evaluate to true
.
property
value to be present in the given
expression
to evaluate to true
.
property
against the given expression
using
the given operator
.
property
against the given expression
using
the given operator
.
message
.
message
and cause
.
message
and cause
.
eventStore
and cache
to
retrieve aggregate instances.
transactional
flag
Map
of Entities capable of handling Commands on behalf
of the aggregate.message
.
message
and cause
.
commandBus
.
saga
to the registered repository.
AggregateRoot.addEventRegistrationCallback(EventRegistrationCallback)
).
AggregateRoot.addEventRegistrationCallback(EventRegistrationCallback)
).
transactionStatus
.
delegates
.
eventStreamDecorators
.
message
.
message
and cause
.
message
.
message
and cause
.
message
.
message
and cause
.
loadFactor
.
message
.
message
and cause
.
Connection.close()
method.nodeName
, segmentCount
supporting given
supportedCommandTypes
.
associationValue
.
key
.
source
, of type sourceType
to the given targetType
.
original
IntermediateRepresentation to the target data type.
correlationIdKey
.
message
.
retryPolicy
.
eventMessage
.
autowiredTypes
.
autowiredTypes
.
instance
.
method
, using given explicitPayloadType
(if not null
) defining the payload of the message it supports.
gatewayInterface
.
parameterType
for a given message.
cacheEntryListener
.
aggregateFactory
.
aggregateFactory
.
aggregateFactory
.
typeIdentifier
of which passed events are
available in the given eventStream
.
dataSource
to obtain new connections.
DBObject
structure that has been created
using the DBObjectHierarchicalStreamWriter
.root
DBObject.
DBObject
structure that has been created
using the DBObjectHierarchicalStreamWriter
.root
DBObject.
root
DBObject.
root
DBObject.
charset
.
charset
and xStream
instance.
charset
, xStream
and
revisionResolver
instance.
charset
and xStream
instance.
charset
.
charset
and xStream
instance.
charset
, xStream
and
revisionResolver
instance.
charset
and xStream
instance.
message
.
getter
" and parameters of type
parameterTypes
is declared.
queueName
.
serializer
, using a PackageRoutingKeyResolver
and requesting durable dispatching.
serializer
, routingKeyResolver
and
requesting durable dispatching when durable
is true
.
SimpleCluster
with
identifier "default", to which this instance will assign all Event Listeners.
defaultCluster
to each listener.
commandBus
after they have been
handles by the given commandDispatchInterceptors
.
commandBus
after they have been
handles by the given commandDispatchInterceptors
.
commandBus
after they have been
handles by the given commandDispatchInterceptors
.
retryPolicy
when an error occurs.
forceUtc
true
, stores the timestamps
converted to UTC timezone.
dataSource
and executing SQL
statements using given sqlSchema
.
connectionProvider
and
executing
SQL
statements using given sqlSchema
.
connectionProvider
to obtain
connections.
eventEntryFactory
to provide instances of the
JPA entities to use for persistence.
java.util.UUID
based identifiers.command
, through the
chain
, to the handler
.
MongoTemplate
.mongoDb
for database access, using default database
and collection names.
mongo
instance, and loads events in the collection with
given domainEventsCollectionName
and snapshot events from snapshotEventsCollectionName
,
in a database with given databaseName
.
mongo
instance, and loads events in the collection with
given domainEventsCollectionName
and snapshot events from snapshotEventsCollectionName
,
in a database with given databaseName
.
MongoTemplate
.mongo
for database access, using default database
and collection names.
mongo
instance, and loads events in the collection with given
domainEventsCollectionName
and snapshot events from snapshotEventsCollectionName
, in a
database with given databaseName
.
mongoDb
instance, using default database name ("axonframework")
and collection name ("sagas").
mongo
instance, and loads sagas in the collection with given
sagasCollectionName
, in a database with given databaseName
.
mongoDb
instance, using default database name ("axonframework")
and collection name ("sagas").
mongo
instance, and loads sagas in the collection with given
sagasCollectionName
, in a database with given databaseName
.
transactionManager
when the Unit of Work starts.
UnitOfWorkFactory
implementation that creates instances of the DefaultUnitOfWork
.transactionManager
bytes
.
bytes
.
command
to the CommandHandler subscribed to that type of command
.
command
to the CommandHandler subscribed to that type of command
.
command
to the CommandHandler subscribed to that type of command
.
command
to the CommandHandler subscribed to that type of command
.
Streamable
and Externalizable
interfaces.
commandMessage
, to be serialized using given
serializer
.
<disruptor-command-bus>
elements in the Spring contextCommandBus
that is aware of multiple instances of a CommandBus working together to
spread load.connector
and an AnnotationRoutingStrategy
.
connector
and routingStrategy
.
aggregateIdentifier
.
aggregateIdentifier
.
LockingRepository.doDeleteWithLock(org.axonframework.domain.AggregateRoot)
to perform actual deleting.
EventSourcingRepository.doSaveWithLock(EventSourcedAggregateRoot)
, as Event Sourcing generally doesn't delete
aggregates (not their events).
serializedObject
.
serializedObject
.
tableName
.
event
.
event
.
events
to the given set of eventListeners
, and notify the
given eventProcessingMonitor
after completion.
command
.
LockingRepository.doSaveWithLock(org.axonframework.domain.AggregateRoot)
to perform actual storage.
eventListener
, which has the actual class listenerType
.
body
on the given channel
.
object
to the given expectedFormat
.
listener
with the cache
intermediateRepresentation
into zero or more other representations.
serializedType
into its new format.
upcaster
on the given sourceObject
.
ehCache
instance
AuditDataProvider
that provides no information (empty map).SagaEventHandler
method indicates the end of a
Saga instance's lifecycle.member
accessible via reflection if it is not the case already.
serializedObject
, and returns a SerializedObject with given
expectedContentType
.
expected
object.
expected
object.
property
against the given
expression
.
property
against the given
expression
.
expression
.
expression
.
EventJobDataBinder
in the scheduler context.
JobDataMap
.
eventBus
element from the Axon
namespace.aggregateIdentifier
.
aggregateIdentifier
of
given type
.
JobDataMap
.OrderResolver
instance to define the expected order of two
candidates.orderResolver
to resolve the "order" value.
message
.
message
and originating cause
.
eventBus
to the given
channel
.
eventBus
to the given
channel
.
eventBus
to the given
channel
.
eventBus
to the given
channel
.
input
and deserializes payload
and meta data using the given serializer
.
EventMessageWriter
and EventMessageReader
.output
.
executor
.
retryPolicy
and reporting the given (optional)
error
to indicate a failure.
message
and cause
eventStore
and eventBus
for aggregate of given aggregateType
.
eventBus
.
eventBus
if they accepted by the
given filter
.
eventBus
.
eventBus
if they accepted by the
given filter
.
message
.
eventScheduler
.
DomainEventStream
.aggregateType
.
aggregateFactory
to
create new aggregate instances.
message
.
message
and cause
message
.
identifier
of given
type
.
message
and cause
.
EventBus
, taking active
UnitOfWork into account.eventBus
.
eventBus
.
eventBus
.
matchers
against the event in a list at their respective
index.matchers
match against the event with
the same index in a given List if Events.
matchers
matches against the event at the respective
index in the list.
command
immediately in the current thread.
associationKey
and
associationValue
.
matcher
.
matcher
.
expectedException
to occur during command handler execution.
matcher
.
associationKey
and
associationValue
.
expected
events.
matcher
.
matcher
.
expectedReturnValue
after execution.
matcher
after execution.
duration
.
scheduledTime
.
matcher
has been scheduled to be published after the given
duration
.
matcher
has been scheduled to be published at the given
scheduledTime
.
eventType
has been scheduled for publication after the given
duration
.
eventType
has been scheduled for publication at the given
scheduledTime
.
matcher
.
void
return type on the given command handler.
Comparable
which indicates the two are not equal.
event
as relevant for a Saga of given
sagaType
.
event
.
entry
.
entry
.
type
and given
identifier
starting at given firstSequenceNumber
.
type
and given
identifier
starting at given firstSequenceNumber
.
whereClause
.
whereClause
.
Iterable
of all the fields declared on the given class and its super classes.
InputStream
.inputStream
and
serializer
.
SerializedDomainEventData
.input
and deserializes payload
and meta data using the given serializer
.
DataOutput
.output
.
EventStore
that serializes objects (by default using
XStream) and
writes them to files to disk.serializer
.
eventStore
element form the
Axon namespace.FileSystemSnapshotEventReader.snapshotEventFile
and
skips the correct number of bytes in the given FileSystemSnapshotEventReader.eventFile
.snapshotEventFile
.
FileSystemSnapshotEventWriter.snapshotEventFile
.snapshotEvent
to the given
snapshotEventFile
.
expectedType
contained in the given collection
.
type
that have been associated with the given
associationValue
.
type
associated with the given
associationValue
.
aggregateType
and
aggregateIdentifier
, with a sequence number equal or higher than the given
firstSequenceNumber
.
criteria
in the given collection
aggregateType
and
aggregateIdentifier
, with a sequence number equal or higher than the given
firstSequenceNumber
.
criteria
in the given collection
message
, or null
if no such handler
exists.
parameterType
.
target
for the given event
.
aggregateType
and
aggregateIdentifier
in the given collection
.
aggregateType
and
aggregateIdentifier
in the given collection
.
associationValue
.
value
for each incoming message.
revision
, when asked.
message
.
message
and cause
.
clazz
.
classLoader
.
constructor
.
message
.
metaDataEntries
.
EventMessage
(or its payload) from a JobDataMap
.
typeByte
.
eventSerializer
.
commandBus
, optionally intercepting them with
given dispatchInterceptors
.
commandBus
, optionally intercepting them with
given dispatchInterceptors
.
commandBus
, optionally intercepting them with
given dispatchInterceptors
.
aggregateType
.
aggregateType
and using the
given parameterResolverFactory
to resolve parameters of annotated event handler methods.
command
as payload and empty metaData
command
as payload.
command
as payload.
command
as payload and a custom chosen
identifier
.
aggregateIdentifier
,
with given sequenceNumber
and payload
.
aggregateIdentifier
,
with given sequenceNumber
, metaData
and payload
.
payload
, and an empty MetaData.
payload
and given metaData
.
aggregateType
.
aggregateType
.
aggregateType
with an additional
lockManager
.
aggregateType
with an additional
lockManager
.
payload
using empty meta data.
payload
and meta data
.
null
if no item was stored under that key
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
annotationType
, or null
if no such
annotation is present.
annotationType
from the given annotations
.
null
if no AssociationValue can be found on
the given eventMessage
.
name
.
name
.
instance
.
default configuration
if not explicitly provided.
sourceContentType
to the given targetContentType
.
default configuration
if not explicitly provided.
DomainEventStream
.
null
if
processing did not result in an exception or if execution is not yet finished.
field
in the given object
.
aggregateRoot
.
entityType
.
handlerClass
that contains handler methods
annotated with the given annotationType
.
handlerClass
that contains handler methods
annotated with the given annotationType
.
methodHandler
.
sagaType
.
null
if none
is available.
null
if no events have been committed
before.
null
if no events have been committed.
item
, that supports given commandType
.
event
.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
Property
instance for the
given parameters.
key
.
null
if
none
is available.
null
if no explicit cluster is
configured.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
typeIdentifier
used by the
CommandHandlerInvoker that is running on the current thread.
name
, or null
if no such resource
is available.
null
if the command is not yet executed or
resulted in an exception.
command
.
sagaType
and event
.
event
.
event
.
event
.
event
.
null
if the message wrapping the
object being upcast does not contain a sequence number.
null
if no pre-serialization should be
done.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
default configuration
if not explicitly provided.
target
.
null
if the version is irrelevant.
null
if the aggregate is newly created.
null
if the aggregate is newly created.
XStream
instance, that does the actual
serialization.
domainEvents
as the "given" events.
domainEvents
as the "given" events.
applicationEvent
has been published in the past.
commands
as the command that will provide the "given" events.
commands
as the command that will provide the "given" events.
aggregateType
.
expression
.
expression
.
command
.
command
.
event
in a GenericMessage
ands sends it to the
configured MessageChannel
.
event
in a GenericMessage
ands sends it to the
configured MessageChannel
.
message
.
message
.
event
for handling in the current instance (this
), as well as all the
entities referenced by this instance.
sourceContentType
into the targetContentType
.
identifier
.
true
if the stream has more events, meaning that a call to next()
will not
result in an exception.
true
if the stream has more events, meaning that a call to next()
will not
result in an exception.
aggregateType
and the locking
mechanism provided by the backend storage.
aggregateType
without locking.
aggregateType
and a locking
mechanism based on the given lockManager
.
aggregateType
and a locking
mechanism based on the given lockManager
.
aggregateType
and a locking
mechanism based on the given lockManager
.
aggregateType
and a locking
mechanism based on the given lockManager
.
field
fieldName
, which is declared on the
given
clazz
.
message
and cause
message
.
expression
.
GenericAggregateFactory
.message
and cause
.
message
.
event
triggers the creation of
a new instance.
bean
.
DomainEventStream
.
DomainEventStream
.
saga
.
executor
using the given
interval
and allowing maxRetryCount
retries before giving up permanently.
invokedMethod
, invoked on given proxy
with
given
args
.
target
instance, using the given message
as
source object to provide parameter values.
target
for given message
.
annotationClass
on the target for the given
event
.
expression
.
member
is accessible.
throwable
is a AxonNonTransientException exception or indicates to be
caused by one.
exception
represents a duplicate key violation.
failure
is clearly non-transient.
expression
is false.
currentView
.
member
is public and non-final.
expression
.
targetClass
should be post processed.
key
.
serializedObject
represents a serialized form of a MetaData object,
such as the ones created by this class (see SerializedMetaData.SerializedMetaData(Object, Class)
.
commandHandler
is subscribed to this command bus.
commandHandler
is subscribed to commands of the given
commandType
on this command bus.
exception
is transient (i.e.
expression
is true.
identifierType
is safe to use as aggregate identifier
objectMapper
to serialize and parse the objects to JSON.
revisionResolver
to define revision for each object to serialize, and given converterFactory
to be used by
upcasters.
objectMapper
to serialize and parse the objects to JSON.
objectMapper
to serialize and parse the objects to JSON.
objectMapper
to serialize and parse the objects to JSON.
jCache
instance
eventEntryStore
and serializer
.
eventEntryStore
and an XStreamSerializer
, which serializes events as XML.
EntryStore
and an XStreamSerializer
, which serializes events as XML.
eventEntryStore
and an XStreamSerializer
, which serializes events as XML.
propertyName
.
connectionProvider
to obtain connections to the
database, using a Generic SQL Schema.
dataSource
to obtain connections to the database, and
given sqldef
to execute SQL statements.
connectionProvider
to obtain connections to the
database, and given sqldef
to execute SQL statements.
connectionProvider
to obtain connections to the
database, and given sqldef
to execute SQL statements and serializer
to serialize
Sagas.
message
and cause
loadFactor
.Streamable
and Externalizable
interfaces.
loadFactor
.
XStreamSerializer
, which
serializes events as XML and the default Event Entry store.
eventEntryStore
and an XStreamSerializer
, which serializes events as XML.
eventSerializer
and stores the
events in the database using the default EventEntryStore.
eventSerializer
and stores the
events in the database using the given eventEntryStore
.
eventStore
element form the Axon
namespace.propertyName
.
JavaSerializer
.
objectMapper
to convert the JSonNode into bytes.
message
and violations
.
deserializedObject
object instance.
upcasters
and a ChainingConverterFactory
to
convert between content types.
serializer
and upcasters
.
converterFactory
and upcasters
.
expression
.
expression
.
matchers
match against at least one item in a given List.matchers
match against at least one
item in any given List.
matchers
matches any of the Events in that
list.
matchers
match against at least one item in a given List.matchers
matches against at least one
item in a given List.
aggregateIdentifier
, expecting the version of the aggregate
to be equal to the given expectedVersion
.
aggregateIdentifier
, expecting the version of the aggregate
to be equal to the given expectedVersion
.
aggregateIdentifier
, expecting the version of the aggregate
to be equal to the given expectedVersion
.
type
with given identifier
.
type
with given identifier
using given entityManager
.
message
and cause
message
.
lockManager
.
message
.
loggerName
.
filters
message
.
message
and cause
.
message
.
message
.
message
.
item
.
matcherIterator
against null
.
groupId
and artifactId
.
groupId
and artifactId
.
input
method
accessible for reflection.
dest
is responsible for providing the value to invoke the
given callback
with.
message
.
message
and cause
.
this
, combined with the given
additionalEntries
.
MessageHandler
.eventListener
.
MessageHandler
.eventListener
.
message
and cause
.
target
object that has handler method annotated with
given annotationType
.
SerializationAware
support.payloadMatcher
matches that message's payload.
key
.items
as content.
identifierKey
as the MetaData
key to the aggregate identifier, and a null
(ignored) version.
identifierKey
as the MetaData
key to the aggregate identifier, and the given versionKey
as key to the (optional) version entry.
metaDataKey
is used to get the Meta Data
value.
metaDataKey
is used to get the Meta Data
value.
accessorMethod
to access a property with given
propertyName
.
MethodMessageHandlerInspector
).Iterable
of all the methods declared on the given class and its super classes.
EventStore
based on a MongoDB instance or replica set.mongoTemplate
, eventSerializer
and
storageStrategy
.
EventStore
based on a MongoDB instance or replica set.