Package | Description |
---|---|
org.axonframework.commandhandling.model | |
org.axonframework.commandhandling.model.inspection | |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.messaging.unitofwork | |
org.axonframework.serialization |
Classes related to message processing in Axon Framework.
|
org.axonframework.serialization.json | |
org.axonframework.serialization.upcasting.event | |
org.axonframework.test.aggregate | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Method and Description |
---|---|
static ApplyMore |
AggregateLifecycle.apply(Object payload,
MetaData metaData)
Apply a
DomainEventMessage with given payload and metadata (metadata from interceptors will be combined
with the provided metadata). |
protected abstract <T> ApplyMore |
AggregateLifecycle.doApply(T payload,
MetaData metaData)
Apply a
DomainEventMessage with given payload and metadata (metadata from interceptors will be combined
with the provided metadata). |
Modifier and Type | Method and Description |
---|---|
protected <P> EventMessage<P> |
AnnotatedAggregate.createMessage(P payload,
MetaData metaData)
|
protected <P> ApplyMore |
AnnotatedAggregate.doApply(P payload,
MetaData metaData) |
Modifier and Type | Method and Description |
---|---|
<P> ApplyMore |
EventSourcedAggregate.doApply(P payload,
MetaData metaData) |
Modifier and Type | Method and Description |
---|---|
MetaData |
MetaData.and(String key,
Object value)
Returns a MetaData instances containing the current entries, and the given
key and given
value . |
MetaData |
MetaData.andIfNotPresent(String key,
Supplier<Object> value)
Returns a MetaData instances containing the current entries, and the given
key if it was
not yet present in this MetaData. |
static MetaData |
MetaData.emptyInstance()
Returns an empty MetaData instance.
|
static MetaData |
MetaData.from(Map<String,?> metaDataEntries)
Creates a new MetaData instance from the given
metaDataEntries . |
MetaData |
MessageDecorator.getMetaData() |
MetaData |
Message.getMetaData()
Returns the meta data for this event.
|
MetaData |
GenericMessage.getMetaData() |
MetaData |
MetaData.mergedWith(Map<String,?> additionalEntries)
Returns a MetaData instance containing values of
this , combined with the given
additionalEntries . |
MetaData |
MetaData.subset(String... keys)
Returns a MetaData instance containing a subset of the
keys in this instance. |
static MetaData |
MetaData.with(String key,
Object value)
Creates a MetaData instances with a single entry, with the given
key and
given value . |
MetaData |
MetaData.withoutKeys(Set<String> keys)
Returns a MetaData instance with the items with given
keys removed. |
Modifier and Type | Method and Description |
---|---|
protected Message<T> |
GenericMessage.withMetaData(MetaData metaData) |
protected abstract Message<T> |
AbstractMessage.withMetaData(MetaData metaData)
Returns a new message instance with the same payload and properties as this message but given
metaData . |
Modifier and Type | Method and Description |
---|---|
static MetaData |
CurrentUnitOfWork.correlationData()
Returns the Correlation Data attached to the current Unit of Work, or an empty
MetaData instance
if no Unit of Work is started. |
MetaData |
UnitOfWork.getCorrelationData()
Get the correlation data contained in the
message being processed by the Unit of Work. |
MetaData |
AbstractUnitOfWork.getCorrelationData() |
Modifier and Type | Method and Description |
---|---|
MetaData |
SerializedMessage.getMetaData() |
Modifier and Type | Method and Description |
---|---|
protected SerializedMessage<T> |
SerializedMessage.withMetaData(MetaData metaData) |
Constructor and Description |
---|
SerializedMessage(String identifier,
LazyDeserializingObject<T> payload,
LazyDeserializingObject<MetaData> metaData)
Initializes a
SerializedMessage with given identifier from the given lazily deserializing payload
and metadata. |
Modifier and Type | Method and Description |
---|---|
MetaData |
MetaDataDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jp,
com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
LazyDeserializingObject<MetaData> |
UpcastedEventRepresentation.getMetaData() |
LazyDeserializingObject<MetaData> |
IntermediateEventRepresentation.getMetaData()
Returns the meta data of the message wrapping the object being upcast.
|
LazyDeserializingObject<MetaData> |
InitialEventRepresentation.getMetaData() |
Modifier and Type | Method and Description |
---|---|
<S> IntermediateEventRepresentation |
UpcastedEventRepresentation.upcast(SerializedType outputType,
Class<S> expectedRepresentationType,
Function<S,S> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction) |
<S> IntermediateEventRepresentation |
UpcastedEventRepresentation.upcast(SerializedType outputType,
Class<S> expectedRepresentationType,
Function<S,S> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction) |
<T> IntermediateEventRepresentation |
IntermediateEventRepresentation.upcast(SerializedType outputType,
Class<T> expectedRepresentationType,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction)
Upcast the serialized payload of the event (leaving other aspects of the event the same).
|
<T> IntermediateEventRepresentation |
IntermediateEventRepresentation.upcast(SerializedType outputType,
Class<T> expectedRepresentationType,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction)
Upcast the serialized payload of the event (leaving other aspects of the event the same).
|
<T> IntermediateEventRepresentation |
InitialEventRepresentation.upcast(SerializedType outputType,
Class<T> expectedRepresentationType,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction) |
<T> IntermediateEventRepresentation |
InitialEventRepresentation.upcast(SerializedType outputType,
Class<T> expectedRepresentationType,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction) |
Constructor and Description |
---|
UpcastedEventRepresentation(SerializedType outputType,
IntermediateEventRepresentation source,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction,
Class<T> requiredType,
Converter converter)
Initializes an
UpcastedEventRepresentation from source data and given upcast functions for payload and
metadata. |
UpcastedEventRepresentation(SerializedType outputType,
IntermediateEventRepresentation source,
Function<T,T> upcastFunction,
Function<MetaData,MetaData> metaDataUpcastFunction,
Class<T> requiredType,
Converter converter)
Initializes an
UpcastedEventRepresentation from source data and given upcast functions for payload and
metadata. |
Modifier and Type | Method and Description |
---|---|
protected <T> ApplyMore |
StubAggregateLifecycle.doApply(T payload,
MetaData metaData) |
Modifier and Type | Method and Description |
---|---|
Object |
DefaultCallbackBehavior.handle(Object commandPayload,
MetaData commandMetaData) |
Object |
CallbackBehavior.handle(Object commandPayload,
MetaData commandMetaData)
Invoked when the Command Bus receives a Command that is dispatched with a Callback method.
|
Copyright © 2010–2018. All rights reserved.