Package | Description |
---|---|
org.axonframework.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.gae.eventstore | |
org.axonframework.quickstart | |
org.axonframework.saga.repository.jdbc | |
org.axonframework.saga.repository.jpa | |
org.axonframework.serializer | |
org.axonframework.serializer.bson | |
org.axonframework.serializer.json | |
org.axonframework.serializer.xml | |
org.axonframework.upcasting |
Modifier and Type | Method and Description |
---|---|
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Stores the given
event (serialized as serializedPayload and
serializedMetaData in the Event Store. |
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Stores the given
event (serialized as serializedPayload and
serializedMetaData in the Event Store. |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Persists the given
event which has been serialized into serializedEvent . |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Persists the given
event which has been serialized into serializedEvent . |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
Modifier and Type | Method and Description |
---|---|
SerializedObject<T> |
SimpleSerializedDomainEventData.getMetaData() |
SerializedObject<byte[]> |
AbstractEventEntry.getMetaData() |
SerializedObject<T> |
SimpleSerializedDomainEventData.getPayload() |
SerializedObject<byte[]> |
AbstractEventEntry.getPayload() |
Modifier and Type | Method and Description |
---|---|
Object |
DefaultEventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
DefaultEventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
EventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Domain Event, which contains the data provided in the parameters, which can be
stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
Object |
EventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Domain Event, which contains the data provided in the parameters, which can be
stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
protected Object |
DefaultEventEntryStore.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the DomainEventEntry to store.
|
protected Object |
DefaultEventEntryStore.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the DomainEventEntry to store.
|
Object |
DefaultEventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
DefaultEventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
EventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Snapshot Event, which contains the data provided in the parameters, which can
be stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
Object |
EventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Snapshot Event, which contains the data provided in the parameters, which can
be stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
protected Object |
DefaultEventEntryStore.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the SnapshotEventEntry to store.
|
protected Object |
DefaultEventEntryStore.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the SnapshotEventEntry to store.
|
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager) |
Constructor and Description |
---|
AbstractEventEntry(String type,
DomainEventMessage event,
org.joda.time.DateTime timestamp,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
AbstractEventEntry(String type,
DomainEventMessage event,
org.joda.time.DateTime timestamp,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
AbstractEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
AbstractEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
org.joda.time.DateTime dateTime,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
org.joda.time.DateTime dateTime,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
SimpleSerializedDomainEventData(String eventIdentifier,
String aggregateIdentifier,
long sequenceNumber,
Object timestamp,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Initialize an instance using given properties.
|
SimpleSerializedDomainEventData(String eventIdentifier,
String aggregateIdentifier,
long sequenceNumber,
Object timestamp,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Initialize an instance using given properties.
|
SnapshotEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
SnapshotEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
Modifier and Type | Method and Description |
---|---|
SerializedObject<String> |
EventEntry.getMetaData() |
SerializedObject<String> |
EventEntry.getPayload() |
Modifier and Type | Method and Description |
---|---|
org.dom4j.Document |
RunUpcaster.ToDoItemUpcaster.doUpcast(SerializedObject<org.dom4j.Document> intermediateRepresentation,
UpcastingContext context) |
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 | 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 |
---|---|
SerializedObject<T> |
ContentTypeConverter.convert(SerializedObject<S> original)
Converts the data format of the given
original IntermediateRepresentation to the target data type. |
SerializedObject<T> |
ChainedConverter.convert(SerializedObject<S> original) |
SerializedObject<T> |
AbstractContentTypeConverter.convert(SerializedObject<S> original) |
SerializedObject<T> |
SerializedDomainEventData.getMetaData()
Returns the serialized data of the MetaData of the serialized Event.
|
SerializedObject<T> |
SerializedDomainEventData.getPayload()
Returns the serialized data of the Event Message's payload.
|
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)
Serialize the given
object into a Serialized Object containing the given
expectedRepresentation . |
<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) |
<R> SerializedObject<R> |
SerializedEventMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
<R> SerializedObject<R> |
SerializedDomainEventMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
<R> SerializedObject<R> |
SerializationAwareEventMessage.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) |
<R> SerializedObject<R> |
SerializedEventMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
<R> SerializedObject<R> |
SerializedDomainEventMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
<R> SerializedObject<R> |
SerializationAwareEventMessage.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 |
---|---|
SerializedObject<T> |
ContentTypeConverter.convert(SerializedObject<S> original)
Converts the data format of the given
original IntermediateRepresentation to the target data type. |
SerializedObject<T> |
ChainedConverter.convert(SerializedObject<S> original) |
SerializedObject<T> |
AbstractContentTypeConverter.convert(SerializedObject<S> original) |
<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)
Deserializes the first object read from the given
bytes . |
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) |
SerializedEventMessage(String eventIdentifier,
org.joda.time.DateTime timestamp,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Constructor to reconstruct an EventMessage using serialized data
|
SerializedEventMessage(String eventIdentifier,
org.joda.time.DateTime timestamp,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Constructor to reconstruct an EventMessage using serialized data
|
SerializedMessage(String identifier,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Reconstructs a Message using the given
identifier , serializedPayload ,
serializedMetaData and serializer . |
SerializedMessage(String identifier,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Reconstructs a Message using the given
identifier , serializedPayload ,
serializedMetaData and serializer . |
Modifier and Type | Method and Description |
---|---|
protected Object |
DBObjectXStreamSerializer.doDeserialize(SerializedObject serializedObject,
com.thoughtworks.xstream.XStream xStream) |
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 |
---|---|
Object |
XStreamSerializer.doDeserialize(SerializedObject serializedObject,
com.thoughtworks.xstream.XStream xStream)
Deserialize the given
serializedObject . |
Modifier and Type | Method and Description |
---|---|
protected <S,T> SerializedObject<T> |
AbstractUpcasterChain.ensureCorrectContentType(SerializedObject<S> serializedObject,
Class<T> expectedContentType)
Converts, if necessary, the given
serializedObject , and returns a SerializedObject with given
expectedContentType . |
SerializedObject<T> |
UpcastSerializedDomainEventData.getMetaData() |
SerializedObject<T> |
UpcastSerializedDomainEventData.getPayload() |
Modifier and Type | Method and Description |
---|---|
protected <T> List<SerializedObject<?>> |
SimpleUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context) |
protected <T> List<SerializedObject<?>> |
LazyUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context) |
protected abstract <T> List<SerializedObject<?>> |
AbstractUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context)
Performs the actual upcasting by the given
upcaster on the given sourceObject . |
List<SerializedObject<?>> |
Upcaster.upcast(SerializedObject<T> intermediateRepresentation,
List<SerializedType> expectedTypes,
UpcastingContext context)
Upcasts the given
intermediateRepresentation into zero or more other representations. |
List<SerializedObject<?>> |
AbstractSingleEntryUpcaster.upcast(SerializedObject<T> intermediateRepresentation,
List<SerializedType> expectedTypes,
UpcastingContext context) |
List<SerializedObject> |
UpcasterChain.upcast(SerializedObject serializedObject,
UpcastingContext upcastingContext)
Pass the given
serializedObject through the chain of upcasters. |
List<SerializedObject> |
AbstractUpcasterChain.upcast(SerializedObject serializedObject,
UpcastingContext upcastingContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract T |
AbstractSingleEntryUpcaster.doUpcast(SerializedObject<T> intermediateRepresentation,
UpcastingContext context)
Upcasts the given
intermediateRepresentation into zero or more other representations. |
protected <T> List<SerializedObject<?>> |
SimpleUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context) |
protected <T> List<SerializedObject<?>> |
LazyUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context) |
protected abstract <T> List<SerializedObject<?>> |
AbstractUpcasterChain.doUpcast(Upcaster<T> upcaster,
SerializedObject<?> sourceObject,
List<SerializedType> targetTypes,
UpcastingContext context)
Performs the actual upcasting by the given
upcaster on the given sourceObject . |
protected <S,T> SerializedObject<T> |
AbstractUpcasterChain.ensureCorrectContentType(SerializedObject<S> serializedObject,
Class<T> expectedContentType)
Converts, if necessary, the given
serializedObject , and returns a SerializedObject with given
expectedContentType . |
List<SerializedObject<?>> |
Upcaster.upcast(SerializedObject<T> intermediateRepresentation,
List<SerializedType> expectedTypes,
UpcastingContext context)
Upcasts the given
intermediateRepresentation into zero or more other representations. |
List<SerializedObject<?>> |
AbstractSingleEntryUpcaster.upcast(SerializedObject<T> intermediateRepresentation,
List<SerializedType> expectedTypes,
UpcastingContext context) |
List<SerializedObject> |
UpcasterChain.upcast(SerializedObject serializedObject,
UpcastingContext upcastingContext)
Pass the given
serializedObject through the chain of upcasters. |
List<SerializedObject> |
AbstractUpcasterChain.upcast(SerializedObject serializedObject,
UpcastingContext upcastingContext) |
List<SerializedType> |
ExtendedUpcaster.upcast(SerializedType serializedType,
SerializedObject<T> intermediateRepresentation)
Upcast the given
serializedType into its new format. |
Constructor and Description |
---|
UpcastSerializedDomainEventData(SerializedDomainEventData<T> original,
Object aggregateIdentifier,
SerializedObject<T> upcastPayload)
Reconstruct the given
original SerializedDomainEventData replacing the aggregateIdentifier with
given aggregateIdentifier and payload with upcastPayload . |
Copyright © 2010-2014. All Rights Reserved.