Package | Description |
---|---|
org.axonframework.eventstore.fs |
Package containing classes necessary to implement a FileSystem based implementation of the EventStore
|
org.axonframework.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.gae.eventstore | |
org.axonframework.serializer | |
org.axonframework.upcasting |
Modifier and Type | Method and Description |
---|---|
SerializedDomainEventData |
FileSystemEventMessageReader.readEventMessage()
Reads the next event from the input.
|
Modifier and Type | Method and Description |
---|---|
SerializedDomainEventData<T> |
GenericEventSqlSchema.createSerializedDomainEventData(ResultSet resultSet) |
SerializedDomainEventData<T> |
EventSqlSchema.createSerializedDomainEventData(ResultSet resultSet)
Reads the current entry of the ResultSet into a SerializedDomainEventData.
|
SerializedDomainEventData<T> |
EventEntryStore.loadLastSnapshotEvent(String aggregateType,
Object identifier)
Load the last known snapshot event for aggregate of given
type with given identifier . |
SerializedDomainEventData<T> |
DefaultEventEntryStore.loadLastSnapshotEvent(String aggregateType,
Object identifier) |
Modifier and Type | Method and Description |
---|---|
Iterator<? extends SerializedDomainEventData<T>> |
EventEntryStore.fetchAggregateStream(String aggregateType,
Object identifier,
long firstSequenceNumber,
int batchSize)
Creates an iterator that iterates through the events for an aggregate of given
type and given
identifier starting at given firstSequenceNumber . |
Iterator<SerializedDomainEventData<T>> |
DefaultEventEntryStore.fetchAggregateStream(String aggregateType,
Object identifier,
long firstSequenceNumber,
int fetchSize) |
Iterator<? extends SerializedDomainEventData<T>> |
EventEntryStore.fetchFiltered(String whereClause,
List<Object> parameters,
int batchSize)
Creates an iterator that iterates through the Events that conform to the given sql
whereClause . |
Iterator<SerializedDomainEventData<T>> |
DefaultEventEntryStore.fetchFiltered(String whereClause,
List<Object> parameters,
int batchSize) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventEntry
Data needed by different types of event logs.
|
class |
AbstractEventEntryData<T>
Abstract JPA Entity, which defines all fields except for the payload and metaData field.
|
class |
DomainEventEntry
JPA compliant wrapper around a DomainEvent.
|
class |
SimpleSerializedDomainEventData<T>
Simple implementation of the
SerializedDomainEventData class, used to reduce memory consumptions by queries
accessing Event Entries. |
class |
SnapshotEventEntry
JPA compatible entry that stores data required for the use of snapshot events.
|
Modifier and Type | Method and Description |
---|---|
SerializedDomainEventData<T> |
EventEntryStore.loadLastSnapshotEvent(String aggregateType,
Object identifier,
javax.persistence.EntityManager entityManager)
Load the last known snapshot event for aggregate of given
type with given identifier
using given entityManager . |
Modifier and Type | Method and Description |
---|---|
Iterator<? extends SerializedDomainEventData<T>> |
EventEntryStore.fetchAggregateStream(String aggregateType,
Object identifier,
long firstSequenceNumber,
int batchSize,
javax.persistence.EntityManager entityManager)
Creates an iterator that iterates through the events for an aggregate of given
type and given
identifier starting at given firstSequenceNumber . |
Iterator<SerializedDomainEventData<T>> |
DefaultEventEntryStore.fetchAggregateStream(String aggregateType,
Object identifier,
long firstSequenceNumber,
int batchSize,
javax.persistence.EntityManager entityManager) |
Iterator<? extends SerializedDomainEventData<T>> |
EventEntryStore.fetchFiltered(String whereClause,
Map<String,Object> parameters,
int batchSize,
javax.persistence.EntityManager entityManager)
Creates an iterator that iterates through the Events that conform to the given JPA
whereClause . |
Iterator<SerializedDomainEventData<T>> |
DefaultEventEntryStore.fetchFiltered(String whereClause,
Map<String,Object> parameters,
int batchSize,
javax.persistence.EntityManager entityManager) |
Modifier and Type | Class and Description |
---|---|
class |
EventEntry
Class that represents an event to store in the google app engine data store.
|
Constructor and Description |
---|
SerializedDomainEventMessage(SerializedDomainEventData domainEventData,
Serializer serializer)
Reconstructs a DomainEventMessage using the given
domainEventData , containing data to be
deserialized using the given serializer . |
Modifier and Type | Class and Description |
---|---|
class |
UpcastSerializedDomainEventData<T>
SerializedDomainEventData implementation that can be used to duplicate existing SerializedDomainEventData instances
after upcasting a payload.
|
Modifier and Type | Method and Description |
---|---|
static List<DomainEventMessage> |
UpcastUtils.upcastAndDeserialize(SerializedDomainEventData entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes)
Upcasts and deserializes the given
entry using the given serializer and
upcasterChain . |
Constructor and Description |
---|
SerializedDomainEventUpcastingContext(SerializedDomainEventData domainEventData,
Serializer serializer)
Initializes the UpcastingContext using given serialized
domainEventData . |
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.