|
||||||||||
| 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.