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
CommandMessage s and CommandResultMessage s 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
QueryMessage s and QueryResponseMessage s 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
SubscriptionQueryMessage s, the initial
QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage s 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 TrackingToken s with. |
Modifier and Type | Method and Description |
---|---|
JpaTokenStore.Builder |
JpaTokenStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize TrackingToken s 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.