Package | Description |
---|---|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.distributed.jgroups | |
org.axonframework.eventhandling.amqp | |
org.axonframework.eventhandling.amqp.spring | |
org.axonframework.eventhandling.io | |
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.eventstore.mongo | |
org.axonframework.gae.eventstore | |
org.axonframework.saga.repository.jdbc | |
org.axonframework.saga.repository.jpa | |
org.axonframework.saga.repository.mongo | |
org.axonframework.serializer | |
org.axonframework.serializer.bson | |
org.axonframework.serializer.json | |
org.axonframework.serializer.xml | |
org.axonframework.upcasting |
Modifier and Type | Method and Description |
---|---|
Serializer |
DisruptorConfiguration.getSerializer()
Returns the serializer to perform pre-serialization with, or
null if no pre-serialization should be
done. |
Modifier and Type | Method and Description |
---|---|
DisruptorConfiguration |
DisruptorConfiguration.setSerializer(Serializer newSerializer)
Returns the serializer to perform pre-serialization with, or
null if no pre-serialization should be
done. |
Constructor and Description |
---|
SerializerHandler(Serializer serializer,
int serializerSegmentId,
Class<?> serializedRepresentation)
Initialize the handler using given
serializer and processing the segment Id with given
serializerId (in case of multiple serializer threads). |
Modifier and Type | Method and Description |
---|---|
CommandMessage<?> |
DispatchMessage.getCommandMessage(Serializer serializer)
Returns the CommandMessage wrapped in this Message.
|
Throwable |
ReplyMessage.getError(Serializer serializer)
Returns the error of the command processing.
|
Object |
ReplyMessage.getReturnValue(Serializer serializer)
Returns the returnValue of the command processing.
|
void |
JGroupsConnectorFactoryBean.setSerializer(Serializer serializer)
Sets the serializer used to serialize events before they are dispatched to the destination.
|
Constructor and Description |
---|
DispatchMessage(CommandMessage<?> commandMessage,
Serializer serializer,
boolean expectReply)
Initialized a DispatchMessage for the given
commandMessage , to be serialized using given
serializer . |
JGroupsConnector(org.jgroups.JChannel channel,
String clusterName,
CommandBus localSegment,
Serializer serializer)
Initializes the Connector using given resources.
|
ReplyMessage(String commandIdentifier,
Object returnValue,
Throwable error,
Serializer serializer)
Constructs a message containing a reply to the command with given
commandIdentifier , containing
either given returnValue or error , which uses the given serializer to
deserialize its contents. |
Constructor and Description |
---|
DefaultAMQPMessageConverter(Serializer serializer)
Initializes the AMQPMessageConverter with the given
serializer , using a PackageRoutingKeyResolver and requesting durable dispatching. |
DefaultAMQPMessageConverter(Serializer serializer,
RoutingKeyResolver routingKeyResolver,
boolean durable)
Initializes the AMQPMessageConverter with the given
serializer , routingKeyResolver and
requesting durable dispatching when durable is true . |
Modifier and Type | Method and Description |
---|---|
void |
SpringAMQPTerminal.setSerializer(Serializer serializer)
Sets the serializer to serialize messages with when sending them to the Exchange.
|
Constructor and Description |
---|
EventMessageReader(DataInputStream input,
Serializer serializer)
Creates a new EventMessageReader that reads the data from the given
input and deserializes payload
and meta data using the given serializer . |
EventMessageWriter(DataOutput output,
Serializer serializer)
Creates a new EventMessageWriter writing data to the specified underlying
output . |
Constructor and Description |
---|
FileSystemBufferedReaderDomainEventStream(InputStream inputStream,
Serializer serializer,
UpcasterChain upcasterChain)
Initialize a BufferedReaderDomainEventStream using the given
inputStream and
serializer . |
FileSystemEventMessageWriter(DataOutput output,
Serializer serializer)
Creates a new EventMessageWriter writing data to the specified underlying
output . |
FileSystemEventStore(Serializer serializer,
EventFileResolver eventFileResolver)
Initialize the FileSystemEventStore using the given
serializer . |
FileSystemSnapshotEventReader(InputStream eventFile,
InputStream snapshotEventFile,
Serializer eventSerializer)
Creates a snapshot event reader that reads the latest snapshot from the
snapshotEventFile . |
FileSystemSnapshotEventWriter(InputStream eventFile,
OutputStream snapshotEventFile,
Serializer eventSerializer)
Creates a snapshot event writer that writes any given
snapshotEvent to the given
snapshotEventFile . |
Constructor and Description |
---|
JdbcEventStore(EventEntryStore eventEntryStore,
Serializer serializer)
Initializes a JdbcEventStore using the given
eventEntryStore and serializer . |
Constructor and Description |
---|
JpaEventStore(EntityManagerProvider entityManagerProvider,
Serializer serializer)
Initialize a JpaEventStore which serializes events using the given
eventSerializer and stores the
events in the database using the default EventEntryStore. |
JpaEventStore(EntityManagerProvider entityManagerProvider,
Serializer serializer,
EventEntryStore eventEntryStore)
Initialize a JpaEventStore which serializes events using the given
eventSerializer and stores the
events in the database using the given eventEntryStore . |
Modifier and Type | Method and Description |
---|---|
com.mongodb.DBObject[] |
StorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages)
Generates the DBObject instances that need to be stored for a commit.
|
com.mongodb.DBObject[] |
DocumentPerEventStorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages) |
com.mongodb.DBObject[] |
DocumentPerCommitStorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages) |
List<DomainEventMessage> |
StorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes)
Extracts the individual Event Messages from the given
entry . |
List<DomainEventMessage> |
DocumentPerEventStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes) |
List<DomainEventMessage> |
DocumentPerCommitStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes) |
Constructor and Description |
---|
MongoEventStore(MongoTemplate mongoTemplate,
Serializer eventSerializer,
StorageStrategy storageStrategy)
Initialize the mongo event store with given
mongoTemplate , eventSerializer and
storageStrategy . |
MongoEventStore(Serializer eventSerializer,
MongoTemplate mongo)
Constructor that accepts a Serializer and the MongoTemplate.
|
Modifier and Type | Method and Description |
---|---|
List<DomainEventMessage> |
EventEntry.getDomainEvent(Object actualAggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes)
Returns the actual DomainEvent from the EventEntry using the provided Serializer.
|
Constructor and Description |
---|
GaeEventStore(Serializer eventSerializer)
Constructs and instance using the given
eventSerializer . |
Modifier and Type | Method and Description |
---|---|
void |
JdbcSagaRepository.setSerializer(Serializer serializer)
Sets the Serializer instance to serialize Sagas with.
|
Constructor and Description |
---|
JdbcSagaRepository(ConnectionProvider connectionProvider,
SagaSqlSchema sqldef,
Serializer serializer)
Initializes a Saga Repository, using given
connectionProvider to obtain connections to the
database, and given sqldef to execute SQL statements and serializer to serialize
Sagas. |
Modifier and Type | Method and Description |
---|---|
Saga |
SagaEntry.getSaga(Serializer serializer)
Returns the Saga instance stored in this entry.
|
void |
JpaSagaRepository.setSerializer(Serializer serializer)
Sets the Serializer instance to serialize Sagas with.
|
Constructor and Description |
---|
SagaEntry(Saga saga,
Serializer serializer)
Constructs a new SagaEntry for the given
saga . |
Modifier and Type | Method and Description |
---|---|
Saga |
SagaEntry.getSaga(Serializer serializer)
Returns the Saga instance stored in this entry.
|
void |
MongoSagaRepository.setSerializer(Serializer serializer)
Provide the serializer to use if the default JavaSagaSerializer is not the best solution.
|
Constructor and Description |
---|
SagaEntry(Saga saga,
Serializer serializer)
Constructs a new SagaEntry for the given
saga . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractXStreamSerializer
Abstract implementation for XStream based serializers.
|
class |
JavaSerializer
Serializer implementation that uses Java serialization to serialize and deserialize object instances.
|
class |
MessageSerializer
Wrapper around a serializer that provides
SerializationAware support. |
Modifier and Type | Method and Description |
---|---|
Serializer |
LazyDeserializingObject.getSerializer()
Returns the serializer to deserialize this object
|
Modifier and Type | Method and Description |
---|---|
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 . |
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 . |
Constructor and Description |
---|
LazyDeserializingObject(SerializedObject<?> serializedObject,
Serializer serializer) |
MessageSerializer(Serializer serializer)
Initializes the MessageSerializer as a wrapper around the given serializer.
|
SerializedDomainEventMessage(SerializedDomainEventData domainEventData,
Serializer serializer)
Reconstructs a DomainEventMessage using the given
domainEventData , containing data to be
deserialized using the given serializer . |
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 . |
Modifier and Type | Class and Description |
---|---|
class |
DBObjectXStreamSerializer
XStream based serializer implementation that serializes objects into a Binary JSON structure.
|
Modifier and Type | Class and Description |
---|---|
class |
JacksonSerializer
Serializer implementation that uses Jackson to serialize objects into a JSON format.
|
Modifier and Type | Class and Description |
---|---|
class |
XStreamSerializer
Serializer that uses XStream to serialize and deserialize arbitrary objects.
|
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 |
---|
LazyUpcasterChain(Serializer serializer,
List<Upcaster> upcasters)
Initializes the UpcasterChain with given
serializer and upcasters . |
SerializedDomainEventUpcastingContext(SerializedDomainEventData domainEventData,
Serializer serializer)
Initializes the UpcastingContext using given serialized
domainEventData . |
SimpleUpcasterChain(Serializer serializer,
List<Upcaster> upcasters)
Initializes the UpcasterChain with given
serializer and upcasters . |
Copyright © 2010-2014. All Rights Reserved.