Modifier and Type | Method and Description |
---|---|
MetaData |
GrpcBackedCommandMessage.getMetaData() |
Modifier and Type | Method and Description |
---|---|
MetaData |
GrpcBackedResponseMessage.getMetaData() |
MetaData |
GrpcBackedQueryMessage.getMetaData() |
Modifier and Type | Method and Description |
---|---|
MetaData |
GrpcBackedSubscriptionQueryMessage.getMetaData() |
Modifier and Type | Method and Description |
---|---|
MetaData |
GrpcMetaDataConverter.convert(Map<String,io.axoniq.axonserver.grpc.MetaDataValue> metaDataMap)
Convert the given
Map of MetaDataValue s to a Map containing the Java representations of each of
those values. |
MetaData |
GrpcMetaData.get() |
Modifier and Type | Method and Description |
---|---|
Map<String,io.axoniq.axonserver.grpc.MetaDataValue> |
GrpcMetadataSerializer.apply(MetaData metaData) |
Modifier and Type | Method and Description |
---|---|
default <R> CompletableFuture<R> |
CommandGateway.send(Object command,
MetaData metaData)
Sends the given
command with the given metaData and returns a CompletableFuture
immediately, without waiting for the command to execute. |
default <R> R |
CommandGateway.sendAndWait(Object command,
MetaData metaData)
Sends the given
command with the given metaData and wait for it to execute. |
default <R> R |
CommandGateway.sendAndWait(Object command,
MetaData metaData,
long timeout,
TimeUnit unit)
Sends the given
command with the given metaData and wait for it to execute. |
Modifier and Type | Method and Description |
---|---|
MetaData |
JpaDeadLetter.diagnostics() |
Modifier and Type | Method and Description |
---|---|
void |
DeadLetterEntry.setDiagnostics(MetaData diagnostics,
Serializer serializer)
Sets the diagnostics, taking in a
Serializer to serialize if to the correct format. |
DeadLetter<M> |
JpaDeadLetter.withDiagnostics(MetaData diagnostics) |
Constructor and Description |
---|
DeadLetterEntry(String processingGroup,
String sequenceIdentifier,
long sequenceIndex,
DeadLetterEventEntry message,
Instant enqueuedAt,
Instant lastTouched,
Cause cause,
MetaData diagnostics,
Serializer serializer)
Creates a new
DeadLetterEntry consisting of the given parameters. |
JpaDeadLetter(DeadLetterEntry entry,
MetaData diagnostics,
M message)
Constructs a new
JpaDeadLetter from a DeadLetterEntry , deserialized diagnostics and a
reconstructed message. |
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 message.
|
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 |
---|---|
MetaData |
GenericDeadLetter.diagnostics() |
MetaData |
DeadLetter.diagnostics()
The diagnostic
MetaData concerning this letter. |
Modifier and Type | Method and Description |
---|---|
DeadLetter<M> |
GenericDeadLetter.withDiagnostics(MetaData diagnostics) |
DeadLetter<M> |
DeadLetter.withDiagnostics(MetaData diagnostics)
Construct a copy of this
DeadLetter , replacing the DeadLetter.diagnostics() with the given
diagnostics . |
Modifier and Type | Method and Description |
---|---|
static <M extends Message<?>> |
Decisions.enqueue(Throwable enqueueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Construct a
ShouldEnqueue defining that a dead letter should be enqueued because of
the given enqueueCause . |
static <M extends Message<?>> |
Decisions.requeue(Throwable requeueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Construct a
ShouldEnqueue defining that a dead letter should be requeued because of
the given requeueCause . |
default DeadLetter<M> |
DeadLetter.withDiagnostics(UnaryOperator<MetaData> diagnosticsBuilder)
Construct a copy of this
DeadLetter , replacing the DeadLetter.diagnostics() with the result of
the given diagnosticsBuilder . |
Constructor and Description |
---|
GenericDeadLetter(Object sequenceIdentifier,
M message,
Cause cause,
Instant enqueuedAt,
Instant lastTouched,
MetaData diagnostics)
Construct a
GenericDeadLetter defining all the fields. |
Constructor and Description |
---|
ShouldEnqueue(Throwable enqueueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Constructs a default
EnqueueDecision to enqueue using the given enqueueCause as the
ShouldEnqueue.enqueueCause() . |
Modifier and Type | Method and Description |
---|---|
MetaData |
ConvertingResponseMessage.getMetaData() |
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 |
---|---|
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 |
---|---|
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–2023. All rights reserved.