| Constructor and Description |
|---|
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy)
Instantiate an Axon Server
CommandBus client. |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator)
Instantiate an Axon Server Command Bus client.
|
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
CommandMessages and CommandResultMessages into Axon
Server gRPC messages and vice versa. |
GrpcBackedCommandMessage(Command command,
Serializer serializer)
Instantiate a
GrpcBackedCommandMessage with the given command and using the provided
Serializer to be able to retrieve the payload and MetaData from it. |
| Modifier and Type | Method and Description |
|---|---|
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer used to serialize and deserialize the Event Message's payload and Meta Data
with. |
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.snapshotSerializer(Serializer snapshotSerializer)
Sets the
Serializer used to serialize and deserialize snapshots. |
| Constructor and Description |
|---|
EventBuffer(EventUpcaster upcasterChain,
Serializer serializer)
Initializes an Event Buffer, passing messages through given
upcasterChain and deserializing events using
given serializer. |
| Constructor and Description |
|---|
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator)
Creates an instance of the Axon Server
QueryBus client. |
GrpcBackedQueryMessage(QueryRequest queryRequest,
Serializer messageSerializer,
Serializer serializer)
Instantiate a
GrpcBackedResponseMessage with the given queryRequest, using the provided
messageSerializer to be able to retrieve the payload and MetaData from it. |
GrpcBackedResponseMessage(QueryResponse queryResponse,
Serializer serializer)
Instantiate a
GrpcBackedResponseMessage with the given queryResponse, using the provided
Serializer to be able to retrieve the payload and MetaData from it. |
QuerySerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
QueryMessages and QueryResponseMessages into Axon
Server gRPC messages and vice versa. |
| Constructor and Description |
|---|
GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
Serializer messageSerializer,
Serializer serializer)
Instantiate a
GrpcBackedSubscriptionQueryMessage with the given subscriptionQuery, using the
provided messageSerializer to be able to retrieve the payload and MetaData from it. |
SubscriptionMessageSerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
SubscriptionQueryMessages, the initial
QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessages into Axon Server gRPC
messages and vice versa. |
| Constructor and Description |
|---|
GrpcMetaData(Map<String,MetaDataValue> metaDataValues,
Serializer serializer)
Instantiate a wrapper around the given
metaDataValues providing access to them as a MetaData
object. |
GrpcMetaDataConverter(Serializer serializer)
Initialize the converter, using the given
serializer to serialize Objects. |
GrpcObjectSerializer(Serializer serializer) |
GrpcPayloadSerializer(Serializer messageSerializer) |
| Modifier and Type | Method and Description |
|---|---|
CommandMessage<?> |
DispatchMessage.getCommandMessage(Serializer serializer)
Returns the CommandMessage wrapped in this Message.
|
CommandResultMessage<?> |
ReplyMessage.getCommandResultMessage(Serializer serializer)
Returns a
CommandResultMessage containg the result of command processing. |
| Constructor and Description |
|---|
DispatchMessage(CommandMessage<?> commandMessage,
Serializer serializer,
boolean expectReply)
Initialized a DispatchMessage for the given
commandMessage, which uses the given
serializer to deserialize its contents. |
ReplyMessage(String commandIdentifier,
CommandResultMessage<?> commandResultMessage,
Serializer serializer)
Initializes a ReplyMessage containing a reply to the command with given {commandIdentifier} and given
commandResultMessage. |
| Modifier and Type | Method and Description |
|---|---|
protected Serializer |
DefaultConfigurer.defaultSerializer(Configuration config)
Provides the default Serializer implementation.
|
Serializer |
Configuration.eventSerializer()
Returns the
Serializer defined in this Configuration to be used for serializing Event Message payload
and their metadata. |
Serializer |
Configuration.messageSerializer()
Returns the
Serializer defined in this Configuration to be used for serializing Message payloads and
metadata. |
default Serializer |
Configuration.serializer()
Returns the serializer defined in this Configuration
|
| Modifier and Type | Method and Description |
|---|---|
Configurer |
Configurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
Configurer |
DefaultConfigurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder) |
Configurer |
Configurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
Configurer |
DefaultConfigurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder) |
default Configurer |
Configurer.configureSerializer(Function<Configuration,Serializer> serializerBuilder)
Configures the given Serializer to use in this configuration.
|
| Modifier and Type | Method and Description |
|---|---|
static DeadlineMessage |
DeadlineJob.DeadlineJobDataBinder.deadlineMessage(Serializer serializer,
org.quartz.JobDataMap jobDataMap)
Extracts a
DeadlineMessage from provided jobDataMap. |
static ScopeDescriptor |
DeadlineJob.DeadlineJobDataBinder.deadlineScope(Serializer serializer,
org.quartz.JobDataMap jobDataMap)
|
QuartzDeadlineManager.Builder |
QuartzDeadlineManager.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize the DeadlineMessage and the ScopeDescriptor
into the JobDataMap. |
static org.quartz.JobDataMap |
DeadlineJob.DeadlineJobDataBinder.toJobData(Serializer serializer,
DeadlineMessage deadlineMessage,
ScopeDescriptor deadlineScope)
Serializes the provided
deadlineMessage and deadlineScope and puts them in a JobDataMap. |
| Modifier and Type | Method and Description |
|---|---|
static Stream<TrackedEventMessage<?>> |
EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain. |
| Constructor and Description |
|---|
AbstractDomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new event entry from a published domain event message to enable storing the event or sending it to a
remote location.
|
AbstractEventEntry(EventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new event entry from a published event message to enable storing the event or sending it to a remote
location.
|
AbstractSequencedDomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new default domain event entry from a published domain event message to enable storing the event or
sending it to a remote location.
|
| Constructor and Description |
|---|
DirectEventJobDataBinder(Serializer serializer)
Instantiate a
QuartzEventScheduler.DirectEventJobDataBinder with the provided Serializer for
de-/serializing event messages. |
| Modifier and Type | Method and Description |
|---|---|
TrackingToken |
AbstractTokenEntry.getToken(Serializer serializer)
Returns the token, deserializing it with given
serializer |
void |
GenericTokenEntry.updateToken(TrackingToken token,
Serializer serializer) |
abstract void |
AbstractTokenEntry.updateToken(TrackingToken token,
Serializer serializer)
Update this entry with the given
token, serializing it using given serializer. |
protected void |
AbstractTokenEntry.updateToken(TrackingToken token,
Serializer serializer,
Class<T> contentType)
Update the token data to the given
token, using given serializer to serialize it to the given
contentType. |
| Constructor and Description |
|---|
AbstractTokenEntry(TrackingToken token,
Serializer serializer,
Class<T> contentType)
Initializes a new token entry for given
token, process and segment. |
GenericTokenEntry(TrackingToken token,
Serializer serializer,
Class<T> contentType,
String processorName,
int segment)
Initializes a new token entry for given
token, process and segment. |
| Modifier and Type | Method and Description |
|---|---|
JdbcTokenStore.Builder |
JdbcTokenStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize TrackingTokens with. |
| Modifier and Type | Method and Description |
|---|---|
JpaTokenStore.Builder |
JpaTokenStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize TrackingTokens with. |
void |
TokenEntry.updateToken(TrackingToken token,
Serializer serializer) |
| Constructor and Description |
|---|
TokenEntry(String processorName,
int segment,
TrackingToken token,
Serializer serializer)
Initializes a new token entry for given
token, processorName and segment. |
| Modifier and Type | Method and Description |
|---|---|
static DomainEventStream |
EventStreamUtils.upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain. |
| Modifier and Type | Method and Description |
|---|---|
Serializer |
AbstractEventStorageEngine.getEventSerializer()
Get the serializer used by this storage engine when storing and retrieving events.
|
Serializer |
AbstractEventStorageEngine.getSnapshotSerializer()
Get the serializer used by this storage engine when storing and retrieving snapshots.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
AbstractEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events,
Serializer serializer)
Append given
events to the backing database. |
AbstractEventStorageEngine.Builder |
AbstractEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer used to serialize and deserialize the Event Message's payload and Meta Data with. |
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer) |
AbstractEventStorageEngine.Builder |
AbstractEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer)
Sets the
Serializer used to serialize and deserialize snapshots. |
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer) |
protected abstract void |
AbstractEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer)
Store the given
snapshot of an Aggregate. |
| Constructor and Description |
|---|
AbstractSnapshotEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer,
Class<T> contentType)
Construct a new event entry from a published domain event message to enable storing the event or sending it to a
remote location.
|
EqualRevisionPredicate(RevisionResolver resolver,
Serializer serializer)
Initializes the Predicate with given
resolver to resolve revision of the class represented by the
serialized data. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JdbcEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events,
Serializer serializer) |
protected PreparedStatement |
JdbcEventStorageEngine.appendSnapshot(Connection connection,
DomainEventMessage<?> snapshot,
Serializer serializer)
Creates a statement to append the given
snapshot to the event storage using given connection to
the database. |
JdbcEventStorageEngine.Builder |
JdbcEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer) |
JdbcEventStorageEngine.Builder |
JdbcEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer) |
protected void |
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JpaEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events,
Serializer serializer) |
protected Object |
JpaEventStorageEngine.createEventEntity(EventMessage<?> eventMessage,
Serializer serializer)
Returns a Jpa event entity for given
eventMessage. |
protected Object |
JpaEventStorageEngine.createSnapshotEntity(DomainEventMessage<?> snapshot,
Serializer serializer)
Returns a Jpa snapshot entity for given
snapshot of an aggregate. |
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer) |
JpaEventStorageEngine.Builder |
JpaEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer) |
protected void |
JpaEventStorageEngine.storeSnapshot(DomainEventMessage<?> snapshot,
Serializer serializer) |
| Constructor and Description |
|---|
DomainEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer)
Construct a new default domain event entry from a published domain event message to enable storing the event or
sending it to a remote location.
|
SnapshotEventEntry(DomainEventMessage<?> eventMessage,
Serializer serializer)
Construct a new default snapshot event entry from an aggregate.
|
| Modifier and Type | Method and Description |
|---|---|
default <T> SerializedObject<T> |
ResultMessage.serializeExceptionResult(Serializer serializer,
Class<T> expectedRepresentation)
Serializes the exception result.
|
<R> SerializedObject<R> |
GenericMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
default <R> SerializedObject<R> |
Message.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the meta data of this message to the
expectedRepresentation using given serializer. |
<S> SerializedObject<S> |
MessageDecorator.serializeMetaData(Serializer serializer,
Class<S> expectedRepresentation) |
<R> SerializedObject<R> |
GenericMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
default <R> SerializedObject<R> |
Message.serializePayload(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the payload of this message to the
expectedRepresentation using given serializer. |
<S> SerializedObject<S> |
MessageDecorator.serializePayload(Serializer serializer,
Class<S> expectedRepresentation) |
| Modifier and Type | Method and Description |
|---|---|
JdbcSagaStore.Builder |
JdbcSagaStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize a Saga instance. |
void |
JdbcSagaStore.setSerializer(Serializer serializer)
Sets the Serializer instance to serialize Sagas with.
|
| Modifier and Type | Method and Description |
|---|---|
protected AbstractSagaEntry<?> |
JpaSagaStore.createSagaEntry(Object saga,
String sagaIdentifier,
Serializer serializer)
Intended for clients to override.
|
JpaSagaStore.Builder |
JpaSagaStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize a Saga instance. |
| Constructor and Description |
|---|
AbstractSagaEntry(Object saga,
String sagaIdentifier,
Serializer serializer,
Class<T> contentType)
Constructs a new SagaEntry for the given
saga. |
SagaEntry(T saga,
String sagaIdentifier,
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
Deprecated.
in favor of the
XStreamSerializer and
JacksonSerializer, as direct Java serialization is relatively error
prone. We hence strongly encourage to use either the XStream or Jackson solution in favor of this Serializer
implementation. |
| Modifier and Type | Method and Description |
|---|---|
Serializer |
LazyDeserializingObject.getSerializer()
Returns the serializer to deserialize this object
|
| Modifier and Type | Method and Description |
|---|---|
<R> SerializedObject<R> |
SerializedMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
<T> SerializedObject<T> |
SerializedObjectHolder.serializeMetaData(Serializer serializer,
Class<T> expectedRepresentation) |
<R> SerializedObject<R> |
SerializedMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
<T> SerializedObject<T> |
SerializedObjectHolder.serializePayload(Serializer serializer,
Class<T> expectedRepresentation) |
| Constructor and Description |
|---|
LazyDeserializingObject(SerializedObject<?> serializedObject,
Serializer serializer)
Creates an instance which will deserialize given
serializedObject upon request. |
LazyDeserializingObject(Supplier<SerializedObject<?>> serializedObjectSupplier,
SerializedType serializedType,
Serializer serializer)
Creates an instance which will get the supplied SerializedObject and deserialize it upon request.
|
SerializedMessage(String identifier,
SerializedObject<?> serializedPayload,
SerializedObject<?> serializedMetaData,
Serializer serializer)
Initializes a
SerializedMessage with given identifier from the given serialized payload and
metadata. |
UnknownSerializedType(Serializer serializer,
SerializedObject<?> serializedObject)
Initialize the unknown type, using given
serializer and serializedObject. |
| Modifier and Type | Class and Description |
|---|---|
class |
JacksonSerializer
Serializer implementation that uses Jackson to serialize objects into a JSON format.
|
| Constructor and Description |
|---|
InitialEventRepresentation(EventData<?> eventData,
Serializer serializer)
Initializes an
InitialEventRepresentation from the given eventData. |
| Modifier and Type | Class and Description |
|---|---|
class |
XStreamSerializer
Serializer that uses XStream to serialize and deserialize arbitrary objects.
|
| Modifier and Type | Method and Description |
|---|---|
Serializer |
AxonConfiguration.eventSerializer() |
Serializer |
AxonConfiguration.messageSerializer() |
| Modifier and Type | Method and Description |
|---|---|
Serializer |
AxonAutoConfiguration.eventSerializer(Serializer messageSerializer,
Serializer generalSerializer,
RevisionResolver revisionResolver) |
Serializer |
AxonAutoConfiguration.messageSerializer(Serializer genericSerializer,
RevisionResolver revisionResolver) |
Serializer |
AxonAutoConfiguration.serializer(RevisionResolver revisionResolver) |
| Modifier and Type | Method and Description |
|---|---|
AxonServerCommandBus |
AxonServerAutoConfiguration.axonServerCommandBus(AxonServerConfiguration axonServerConfiguration,
Serializer serializer,
AxonServerConnectionManager axonServerConnectionManager,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandBus localSegment) |
Serializer |
AxonAutoConfiguration.eventSerializer(Serializer messageSerializer,
Serializer generalSerializer,
RevisionResolver revisionResolver) |
EventStorageEngine |
JdbcAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
AxonConfiguration configuration,
ConnectionProvider connectionProvider,
TransactionManager transactionManager) |
EventStorageEngine |
JpaEventStoreAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
AxonConfiguration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager) |
EventStore |
AxonServerAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
AxonConfiguration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
Serializer |
AxonAutoConfiguration.messageSerializer(Serializer genericSerializer,
RevisionResolver revisionResolver) |
AxonServerQueryBus |
AxonServerAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
AxonConfiguration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler) |
JdbcSagaStore |
JdbcAutoConfiguration.sagaStore(ConnectionProvider connectionProvider,
Serializer serializer) |
JpaSagaStore |
JpaAutoConfiguration.sagaStore(Serializer serializer,
EntityManagerProvider entityManagerProvider) |
TokenStore |
JdbcAutoConfiguration.tokenStore(ConnectionProvider connectionProvider,
Serializer serializer) |
TokenStore |
JpaAutoConfiguration.tokenStore(Serializer serializer,
EntityManagerProvider entityManagerProvider) |
Copyright © 2010–2019. All rights reserved.