|
||||||||||
| 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.mongoTemplate, eventSerializer and
storageStrategy.
MongoOptions instance.MongoOptions instance.propertyName.
propertyName.
mongoTemplate to access the collections containing the
stored Saga instances.
mongoTemplate to access the collections containing the
stored Saga instances.
correlationDataProviders.
delegates, in the order provided.
delegates, in the order provided.
targetMonitor as the monitor to eventually forward calls to.
algorithm.
message.
value is not null or empty.
property must not be equal to the given
expression.
property must not be equal to the given
expression.
null or void.
UnitOfWorkListener.afterCommit(UnitOfWork) notification to all registered listeners.
UnitOfWorkListener.onCleanup(UnitOfWork) notification to all
registered listeners.
UnitOfWorkListener.onPrepareCommit(UnitOfWork, java.util.Set,
java.util.List) notification to all registered listeners.
UnitOfWorkListener.afterCommit(UnitOfWork) notification to all registered listeners.
UnitOfWorkListener.onRollback(UnitOfWork, Throwable) notification to all registered listeners.
expression.
value is not null.
AuditLogger that does nothing.null or void value.identifier.
aggregateIdentifier.
aggregateIdentifier.
aggregateIdentifier.
Cache.remove(Object).
aggregateIdentifier and of given type.
aggregateIdentifier and of given type.
aggregateIdentifier and of given type.
aggregateIdentifier and of given type.
LockManager that uses an optimistic locking strategy.this or the given criteria must match.
true.
true.
delegates, which are automatically
ordered based on the @Priority annotation on their respective classes.
delegates, which are automatically
ordered based on the @Priority annotation on their respective classes.
listener.
Event Listeners and the Event Bus.Message.element, using the given defaultSerializer if none is explicitly
configured.
element.
element.
payloadMatcher.
matcher to match the payloads.
matcher.
PersistenceExceptionResolver instead.event (serialized as serializedPayload and
serializedMetaData in the Event Store.
event which has been serialized into serializedEvent in the
backing data store using given entityManager.
event which has been serialized into serializedEvent.
event which has been serialized into serializedEvent in the
backing data store using given entityManager.
LockManager that uses a pessimistic locking strategy.message.
message to the given member.
@Priority
annotation.message and cause.
property, defined in given
targetClass, or null if no such property is found on the class.
type that generated the given
mostRecentSnapshotEvent.
type that generated the given
mostRecentSnapshotEvent.
events to all clusters on the Event Bus.
events as being published somewhere in the past.
event to be published on behalf of an aggregate.
payload on the configured Event Bus.
payload on the configured Event Bus, with given metaData
attached.
event on the given eventBus.
value in the cache, under given key.
value in the cache, under given key, if no element is yet available
under that key.
EventMessage as is to JobDataMap under QuartzEventScheduler.DirectEventJobDataBinder.EVENT_KEY.jobIdentifier and groupIdentifier.
messageBody and headers.
type and identifier, starting at the event with the given firstSequenceNumber (included).
type and identifier, starting at the event with the given firstSequenceNumber (included) up to and including the
event with given lastSequenceNumber.
resultSet at given columnIndex.
resultSet, which has been returned by executing the
Statement returned from SagaSqlSchema.sql_loadSaga(java.sql.Connection, String)
Note: The implementation must not change the resultSet's cursor position
resultSet at given columnIndex.
expression as parameter and returns the value to use to refer to this
expression.
expression as parameter and returns the value to use to refer to this
expression.
aggregateFactory with the fixture.
annotatedCommandHandler with this fixture.
BeanDefinition for the AnnotationCommandHandlerBeanPostProcessor and register it.
BeanDefinition for the AnnotationEventListenerBeanPostProcessor and register it.
mBean as an MBean with the default MBeanServer.
cacheEntryListener to listen for Cache changes.
cluster, assigning it to a listener that listens to the given
queueName.
callback, which is invoked for each sent command, unless Axon is able to detect that
the result of the command does not match the type accepted by the callback.
gatewayInterface and registers that as a resource.
gatewayInterface and registers that as a resource.
commandHandler to handle commands of the given commandType with the
command bus used by this fixture.
commandHandler to handle commands of the given commandType with the
command bus used by this fixture.
converter with this factory.
converterType with this factory, only if initialization of such a
converter is possible.
converterFactory which depend on the actual contents of the
serialized for to represent a JSON format.
dispatchInterceptor which is invoked for each Command dispatched through the
Command Gateways created by this factory.
payload and no
(additional) meta-data.
fieldFilter, which is used to define which Fields are used when comparing
objects.
fieldFilter, which is used to define which Fields are used when comparing
objects.
event for publication on the given eventBus when the unit of work
is committed.
fieldName, which is declared in given declaringClass
is ignored when performing deep equality checks.
fieldName, which is declared in given declaringClass
is ignored when performing deep equality checks.
monitoringBean with the registries on the classpath.
parameterResolverFactory with this aggregate instance.
repository with the fixture.
resource.
sagaFactoryDefinition in the given sagaManagerDefinition.
sagaRepositoryDefinition in the given sagaManagerDefinition.
unitOfWork.
element in the given
sagaManagerDefinition.
types in the given sagaManagerDefinition.
identifier.
aggregateIdentifier.
aggregateIdentifier.
aggregateIdentifier.
message.
message and cause.
key.
associationValue, if it is contained by this instance.
associationValue and sagaIdentifier.
sagaIdentifier.
AssociationValues.commit().
key.
message and cause
delegate, to allow it to replay event from the
given eventStore.
commandMessage to given address using the given channel.
Streamable and Externalizable interfaces.
commandIdentifier, containing
either given returnValue or error, which uses the given serializer to
deserialize its contents.
matcher as a failing matcher.
repository element from the Axon
namespace.handler.
serializedType.
appliedChanges and committedChanges for any conflicting
changes.
appliedChanges and committedChanges for any conflicting
changes.
aggregate, where given unseenEvents may
have been concurrently applied.
dateTime in the event entry.
dateTime in the event entry.
message, or null if no suitable
parameter value can be resolved.
member
primitiveType.
command has created the given aggregate.
eventMessage to the Message Broker.
command should be executed.
storedEvents and publishedEvents.
delegate, representing the actual callback passed as
a parameter to dispatch, the given commandMessage, retryScheduler and
commandBus.
TimeoutConfigurations that
describe which retry timeout should be used for each number of retries.
timeout between retries.
timeout between retries for the given
count number of retries.
payloadType.
throwable should trigger a rollback.
transactionStatus.
RunDistributedCommandBus, only difference is that we use spring to wire all the beans.saga.
saga.
saga.
creationPolicy and initialAssociationValue.
SagaEventHandler annotated methods.sagaType.
message.
message and cause.
event for publication at the given triggerDateTime.
event for publication after the given triggerDuration.
commandMessage that failed with given lastFailure.
typeIdentifier and
aggregateIdentifier.
message.
message and cause.
eventListener should be member of.
eventListener should be member of.
command to the node assigned to handle messages with the given
routingKey.
command to the node assigned to handle messages with the given
routingKey.
command, and invokes the callback when the command is processed.
command, and have the result of the command's execution reported to the given
callback.
command and returns immediately, without waiting for the command to execute.
command and returns immediately.
command and wait for it to execute.
command and wait for it to execute.
command and waits for its execution to complete, or until the waiting thread is
interrupted.
command and waits for its execution to complete, or until the given
timeout has expired, or the waiting thread is interrupted.
EventStores together.matchers each match against an item that the previous
matcher matched against.matchers match against an item
positioned after the item that the previous matcher matched against.
Long type
annotated with the SequenceNumber annotation and assigns the sequenceNumber of the DomainEventMessage.ParameterResolverFactory for SequenceNumber
annotated parameters
matchers match against an Event that comes after the Event
that the previous matcher matched against.
message.
eventMessage.
message.
message and cause.
object into a Serialized Object containing the given
expectedRepresentation.
object into a Serialized Object containing the given
expectedRepresentation.
domainEventData, containing data to be
deserialized using the given serializer.
aggregateIdentifier and sequenceNumber.
domainEventData.
identifier, serializedPayload,
serializedMetaData and serializer.
MetaData instance.bytes representing the serialized form of a MetaData
instance.
message
data, of given type and
revision.
message using given
serializer and expectedRepresentation.
message to the given expectedRepresentation.
serializer, using given
expectedRepresentation.
message using given serializer
and expectedRepresentation.
message to the given expectedRepresentation.
serializer, using given
expectedRepresentation.
serializer and processing the segment Id with given
serializerId (in case of multiple serializer threads).
unitOfWork to the current thread.
commandCallbacks, which are invoked for each sent command, unless Axon is able to detect
that the result of the command does not match the type accepted by that callback.
data as correlation data to the current thread.
correlationDataProviders.
QuartzEventScheduler.DirectEventJobDataBinder instance which reads / writes the event message to publish to the
JobDataMap.
EventJobDataBinder instance which reads / writes the event message to publish to the
JobDataMap.
HashChangeListener with the JGroupsConnector.
metaDataValues in the Cluster.
value under the given key.
null if no pre-serialization should be
done.
EntityManager.flush() after each data modifying
operation on the backing storage.
WaitStrategy, which used to make dependent threads wait for tasks to be completed.
name.
name, using given orderResolver to define the
order in which listeners need to be invoked.
commandBus element from
the
Axon namespace.SimpleCommandBus.metaDataKeys
as correlation data.
DomainEventMessages and aggregate identifier.
entityManager.
EventBus that directly forwards all published events (in the callers' thread) to all
subscribed listeners.SimpleEventBus.baseDir.
EventScheduler implementation that uses Java's ScheduledExecutorService as scheduling and triggering
mechanism.executorService as trigger and execution
mechanism, and publishes events to the given eventBus.
executorService as trigger and execution
mechanism, and publishes events to the given eventBus.
property, operator and
expression
make a match.
property, operator and
expression
make a match.
property, operator and
expression match.
property, operator and
expression match.
resources.
resources.
resource in applicable parameters.
SimpleSagaManager.SimpleSagaManager(Class, SagaRepository, AssociationValueResolver) and register using
EventBus.subscribe(org.axonframework.eventhandling.EventListener)
SimpleSagaManager.SimpleSagaManager(Class, SagaRepository, AssociationValueResolver, SagaFactory) and
register using EventBus.subscribe(org.axonframework.eventhandling.EventListener)
tokenId.
SerializedDomainEventData class, used to reduce memory consumptions by queries
accessing Event Entries.data and serializedType.
data and a serialized type identified by given
type and revision.
objectType and revisionNumber
SerializedObject
to the most recent revision of that payload.upcasters and a ChainingConverterFactory to convert between content types.
serializer and upcasters.
converterFactory and upcasters.
upcasters and using the given converterFactory to
create converters for the intermediate representations used by the upcasters.
event.
aggregateIdentifier of
given type.
snapshotter element form the Axon
namespace.Event Stream Decorators that have the
intent to trigger snapshots.AggregateSnapshotter that eases the configuration when
used within a Spring Application Context.@Order annotations on the type level.dataSource to obtain a connection, when required.
EventBus implementation that delegates all subscription and publishing
requests to a Spring Integration channel.EventBus implementation that delegates all subscription and publishing
requests to a Spring Messaging channel.PlatformTransactionManager as
underlying transaction manager.transactionManager and the default
transaction definition.
DateTime to a data value suitable for the database scheme.
sagaIdentifier.
sagaIdentifier.
type and
identifier, starting at the given firstSequenceNumber.
sagaType associated with the
given association key and value.
type and aggregateIdentifier.
whereClause.
identifier and of given aggregateType.
sagaId.
sequenceOfFirstSnapshotToPrune, for an aggregate of given type and
aggregateIdentifier.
sagaIdentifier, where the
association is identified with given key and value.
key and value, for a
Saga of given type and identifier.
sagaType and with given
sagaIdentifier.
sagaType and with given sagaIdentifier.
properties and use the dataSource
to automatically retrieve the database product name.
eventBus.
transactionManager to provide a backing
transaction, registering it a CurrentUnitOfWork.
criteria.
executor.
executor, only reading events matching the given
criteria.
SagaEventHandler method can trigger the
creation of a new Saga instance.state is true.
associationValue, which has been associated with given sagaIdentifier.
message.
currentDateTime as its conceptual
"current time".
aggregateAnnotationCommandHandler to the given commandBus.
CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler). Retrieve the supported commands with AggregateAnnotationCommandHandler.supportedCommands().
annotationCommandHandler to the given commandBus.
CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler), using AnnotationCommandHandlerAdapter.supportedCommands() to retrieve
the commands the annotated handler supports.
handler to commands of type commandType.
handler to commands of type commandType to the local segment of the
command bus.
handler to commands of type commandType.
handler to commands of type commandType.
bean (with its annotated methods managed by given adapter)
to the messaging infrastructure.
annotatedEventListener to the given eventBus.
EventBus.subscribe(org.axonframework.eventhandling.EventListener) and
pass this adapter instance to subscribe it.
eventListener to this cluster.
eventListener to this bus.
eventListener to this cluster.
eventListener to this bus.
EventBus.subscribe(org.axonframework.eventhandling.EventListener) to subscribe this
instance
monitor.
sagaType.
sagaType.
EventStore and EventStoreManagement, and functions as a filter based on a
DateTime.DateTime that are annotated
with the Timestamp annotation and assigns the timestamp of the EventMessage.ParameterResolverFactory for Timestamp
annotated parameters
eventMessage (or its payload) to a JobDataMap.
TransactionManager, if
necessary (and possible).message and cause.
sagaClass.
delegate to create a new instance, when on is not
already attached to the Unit of Work.
delegate to create a new instance, when on is not
already attached to the Unit of Work.
UnitOfWorkFactory interface is used to obtain UnitOfWork instances to manage activity in command
handling processes.UnitOfWorkListener that provides empty implementation of all methods declared
in UnitOfWorkListener.serializedType
serializedType
PropertyAccessStrategy.register(PropertyAccessStrategy) method.
cacheEntryListener.
CommandBus.unsubscribe(String,
org.axonframework.commandhandling.CommandHandler). Retrieve the supported commands with AggregateAnnotationCommandHandler.supportedCommands().
CommandBus.subscribe(String,
org.axonframework.commandhandling.CommandHandler), using AnnotationCommandHandlerAdapter.supportedCommands() to retrieve
the commands the annotated handler supports.
handler to commands of type commandType.
handler to commands of type commandType.
handler to commands of type commandType.
handler to commands of type commandType.
bean (with its annotated methods managed by given adapter)
to the messaging infrastructure.
EventBus.unsubscribe(org.axonframework.eventhandling.EventListener) and
pass this adapter instance to unsubscribe it.
eventListener from this cluster.
eventListener to this bus.
eventListener from this cluster.
eventListener to this bus.
EventBus.unsubscribe(org.axonframework.eventhandling.EventListener) to unsubscribe this
instance
monitor.
message and the violatingMethod.
serializedType into its new format.
serializedType into its new format.
intermediateRepresentation into zero or more other representations.
serializedType into its new format.
serializedObject through the chain of upcasters.
entry using the given serializer and
upcasterChain.
SerializedObject
to the most recent revision of that payload.original SerializedDomainEventData replacing the aggregateIdentifier with
given aggregateIdentifier and payload with upcastPayload.
additionalData.
saga instance.
command using the given validator.
aggregateIdentifier complies with the toString requirements
and throws IllegalArgumentException if that is not the case.
identifier and version.
EventVisitor.doWithEvent(org.axonframework.domain.DomainEventMessage)
for each event found.
criteria and calls EventVisitor.doWithEvent(org.axonframework.domain.DomainEventMessage) for each event found.
nodeName, which is given
segmentCount segments on the ring.
nodes are available.
metaData.
metaData.
metaData.
metaData.
keys removed.
connection, creating a Proxy with an additional wrapperInterface
(implemented by given wrapperHandler).
connection, creating a Proxy with an additional wrapperInterface
(implemented by given wrapperHandler).
configuration.
message to make it SerializationAware.
message to make it SerializationAware.
delegate in an InvocationHandler that returns immediately after invoking the
delegate.
delegate in an InvocationHandler that returns null when the
delegate
throws an InterruptedException.
delegate in an InvocationHandler that returns null when the
delegate throws a TimeoutException.
delegate and waits for the result in the Future to become available, with given
timeout and timeUnit.
delegate and waits for the result in the Future to become available using given
indices to resolve the parameters that provide the timeout to use.
delegate and waits for the result in the Future to become available.
delegate in an InvocationHandler that wraps exceptions not declared on the method
in a CommandExecutionException.
eventMessage to the underling output.
eventMessage to the underling output.
FileSystemSnapshotEventWriter.snapshotEventFile.
charset.
charset and xStream instance.
charset and xStream instance.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||