Package | Description |
---|---|
org.axonframework.eventhandling.saga.repository.jdbc | |
org.axonframework.eventhandling.saga.repository.jpa | |
org.axonframework.eventhandling.tokenstore | |
org.axonframework.eventsourcing.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.kafka.eventhandling | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.mongo.eventsourcing.eventstore.documentperevent | |
org.axonframework.mongo.serialization | |
org.axonframework.serialization |
Classes related to message processing in Axon Framework.
|
org.axonframework.serialization.json | |
org.axonframework.serialization.upcasting.event | |
org.axonframework.serialization.xml | |
org.axonframework.springcloud.commandhandling |
Modifier and Type | Method and Description |
---|---|
SerializedObject<?> |
SagaSqlSchema.readSerializedSaga(ResultSet resultSet)
Reads a SerializedObject from the given
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 |
SerializedObject<byte[]> |
GenericSagaSqlSchema.readSerializedSaga(ResultSet resultSet) |
Modifier and Type | Class and Description |
---|---|
class |
SerializedSaga
Specialization of the SerializedObject for Sagas represented as byte array.
|
Modifier and Type | Method and Description |
---|---|
SerializedObject<T> |
AbstractTokenEntry.getSerializedToken()
Returns the serialized token.
|
Modifier and Type | Method and Description |
---|---|
SerializedObject<T> |
TrackedDomainEventData.getMetaData() |
SerializedObject<T> |
EventData.getMetaData()
Returns the serialized data of the MetaData of the serialized Event.
|
SerializedObject<T> |
AbstractEventEntry.getMetaData() |
SerializedObject<T> |
TrackedDomainEventData.getPayload() |
SerializedObject<T> |
EventData.getPayload()
Returns the serialized data of the Event Message's payload.
|
SerializedObject<T> |
AbstractEventEntry.getPayload() |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.header.Headers |
HeaderUtils.toHeaders(EventMessage<?> eventMessage,
SerializedObject<byte[]> serializedObject,
BiFunction<String,Object,org.apache.kafka.common.header.internals.RecordHeader> headerValueMapper)
|
Modifier and Type | Method and Description |
---|---|
<S> SerializedObject<S> |
MessageDecorator.serializeMetaData(Serializer serializer,
Class<S> expectedRepresentation) |
<S> SerializedObject<S> |
MessageDecorator.serializePayload(Serializer serializer,
Class<S> expectedRepresentation) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
Headers.defaultHeaders(EventMessage<?> message,
SerializedObject<?> serializedObject)
Generate defaults headers to recognise an event message.
|
Modifier and Type | Method and Description |
---|---|
SerializedObject<Object> |
EventEntry.getMetaData() |
SerializedObject<Object> |
EventEntry.getPayload() |
Modifier and Type | Method and Description |
---|---|
protected Object |
DBObjectXStreamSerializer.doDeserialize(SerializedObject serializedObject,
com.thoughtworks.xstream.XStream xStream) |
Modifier and Type | Class and Description |
---|---|
class |
SerializedMetaData<T>
Represents the serialized form of a
MetaData instance. |
class |
SimpleSerializedObject<T>
SerializedObject implementation that takes all properties as constructor parameters.
|
Modifier and Type | Method and Description |
---|---|
default <T> SerializedObject<T> |
Converter.convert(SerializedObject<?> original,
Class<T> targetType)
Converts the data format of the given
original IntermediateRepresentation to the target data type. |
SerializedObject<?> |
LazyDeserializingObject.getSerializedObject()
Returns the serialized object to deserialize upon request
|
<T> SerializedObject<T> |
Serializer.serialize(Object object,
Class<T> expectedRepresentation)
Serialize the given
object into a Serialized Object containing the given
expectedRepresentation . |
<T> SerializedObject<T> |
MessageSerializer.serialize(Object object,
Class<T> expectedRepresentation) |
<T> SerializedObject<T> |
JavaSerializer.serialize(Object instance,
Class<T> expectedType) |
<T> SerializedObject<T> |
AbstractXStreamSerializer.serialize(Object object,
Class<T> expectedType) |
<T> SerializedObject<T> |
MessageSerializer.serializeMetaData(Message<?> message,
Class<T> expectedRepresentation)
Serialize the meta data of given
message to the given expectedRepresentation . |
static <T> SerializedObject<T> |
MessageSerializer.serializeMetaData(Message<?> message,
Serializer serializer,
Class<T> expectedRepresentation)
Utility method that serializes the meta data of the given
message using given
serializer and expectedRepresentation . |
<R> SerializedObject<R> |
SerializedMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
<T> SerializedObject<T> |
SerializedObjectHolder.serializeMetaData(Serializer serializer,
Class<T> expectedRepresentation) |
<T> SerializedObject<T> |
SerializationAware.serializeMetaData(Serializer serializer,
Class<T> expectedRepresentation)
Serialize the meta data of this message using given
serializer , using given
expectedRepresentation . |
<T> SerializedObject<T> |
MessageSerializer.serializePayload(Message<?> message,
Class<T> expectedRepresentation)
Serialize the payload of given
message to the given expectedRepresentation . |
static <T> SerializedObject<T> |
MessageSerializer.serializePayload(Message<?> message,
Serializer serializer,
Class<T> expectedRepresentation)
Utility method that serializes the payload of the given
message using given serializer
and expectedRepresentation . |
<R> SerializedObject<R> |
SerializedMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
<T> SerializedObject<T> |
SerializedObjectHolder.serializePayload(Serializer serializer,
Class<T> expectedRepresentation) |
<T> SerializedObject<T> |
SerializationAware.serializePayload(Serializer serializer,
Class<T> expectedRepresentation)
Serialize the payload of this message using given
serializer , using given
expectedRepresentation . |
Modifier and Type | Method and Description |
---|---|
default <T> SerializedObject<T> |
Converter.convert(SerializedObject<?> original,
Class<T> targetType)
Converts the data format of the given
original IntermediateRepresentation to the target data type. |
<S,T> T |
Serializer.deserialize(SerializedObject<S> serializedObject)
Deserializes the first object read from the given
bytes . |
<S,T> T |
MessageSerializer.deserialize(SerializedObject<S> serializedObject) |
<S,T> T |
JavaSerializer.deserialize(SerializedObject<S> serializedObject) |
<S,T> T |
AbstractXStreamSerializer.deserialize(SerializedObject<S> serializedObject) |
protected abstract Object |
AbstractXStreamSerializer.doDeserialize(SerializedObject serializedObject,
com.thoughtworks.xstream.XStream xStream)
Deserialize the given
serializedObject . |
static boolean |
SerializedMetaData.isSerializedMetaData(SerializedObject<?> serializedObject)
Indicates whether the given
serializedObject represents a serialized form of a MetaData object,
such as the ones created by this class (see SerializedMetaData.SerializedMetaData(Object, Class) . |
Constructor and Description |
---|
LazyDeserializingObject(SerializedObject<?> serializedObject,
Serializer serializer)
Creates an instance which will deserialize given
serializedObject upon request. |
SerializedMessage(String identifier,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Initializes a
SerializedMessage with given identifier from the given serialized payload and
metadata. |
SerializedMessage(String identifier,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Initializes a
SerializedMessage with given identifier from the given serialized payload and
metadata. |
Constructor and Description |
---|
LazyDeserializingObject(Supplier<SerializedObject<?>> serializedObjectSupplier,
SerializedType serializedType,
Serializer serializer)
Creates an instance which will get the supplied SerializedObject and deserialize it upon request.
|
Modifier and Type | Method and Description |
---|---|
<T> SerializedObject<T> |
JacksonSerializer.serialize(Object object,
Class<T> expectedRepresentation) |
Modifier and Type | Method and Description |
---|---|
<S,T> T |
JacksonSerializer.deserialize(SerializedObject<S> serializedObject) |
Modifier and Type | Method and Description |
---|---|
SerializedObject<T> |
UpcastedEventRepresentation.getData() |
SerializedObject<?> |
IntermediateEventRepresentation.getData()
Get the data of this representation.
|
SerializedObject<?> |
InitialEventRepresentation.getData() |
<D> SerializedObject<D> |
UpcastedEventRepresentation.getData(Class<D> requiredType) |
<D> SerializedObject<D> |
IntermediateEventRepresentation.getData(Class<D> requiredType)
Get the data of this representation.
|
<D> SerializedObject<D> |
InitialEventRepresentation.getData(Class<D> requiredType) |
Modifier and Type | Method and Description |
---|---|
Object |
XStreamSerializer.doDeserialize(SerializedObject serializedObject,
com.thoughtworks.xstream.XStream xStream) |
Constructor and Description |
---|
MessageRoutingInformation(int loadFactor,
SerializedObject<String> serializedCommandFilter) |
Copyright © 2010–2018. All rights reserved.