| Modifier and Type | Method and Description |
|---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize incoming and outgoing commands and command results. |
| Constructor and Description |
|---|
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
CommandMessages and CommandResultMessages into Axon
Server gRPC messages and vice versa. |
GrpcBackedCommandMessage(io.axoniq.axonserver.grpc.command.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 | Class and Description |
|---|---|
class |
GrpcMetaDataAwareSerializer
Wrapper around standard Axon Framework serializer that can deserialize Metadata from AxonServer events.
|
| Modifier and Type | Method and Description |
|---|---|
AxonServerEventStoreFactory.Builder |
AxonServerEventStoreFactory.Builder.eventSerializer(Serializer eventSerializer)
|
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer used to serialize and deserialize the Event Message's payload and Meta Data with. |
AxonServerEventScheduler.Builder |
AxonServerEventScheduler.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer used to de-/serialize events. |
AxonServerEventStoreFactory.Builder |
AxonServerEventStoreFactory.Builder.snapshotSerializer(Serializer snapshotSerializer)
Sets the
Serializer used to serialize and deserialize snapshots. |
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.snapshotSerializer(Serializer snapshotSerializer)
Sets the
Serializer used to serialize and deserialize snapshots. |
| Constructor and Description |
|---|
EventBuffer(io.axoniq.axonserver.connector.event.EventStream delegate,
EventUpcaster upcasterChain,
Serializer serializer,
boolean disableIgnoredEventFiltering)
Initializes an Event Buffer, passing messages through given
upcasterChain and deserializing events using
given serializer. |
GrpcMetaDataAwareSerializer(Serializer delegate)
Constructs a
GrpcMetaDataAwareSerializer, using the given delegate to delegate serialization to |
| Modifier and Type | Method and Description |
|---|---|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.genericSerializer(Serializer genericSerializer)
Sets the generic
Serializer used to de-/serialize incoming and outgoing query
ResponseType implementations. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.messageSerializer(Serializer messageSerializer)
Sets the message
Serializer used to de-/serialize incoming and outgoing queries and query responses. |
| Constructor and Description |
|---|
GrpcBackedQueryMessage(io.axoniq.axonserver.grpc.query.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(io.axoniq.axonserver.grpc.query.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(io.axoniq.axonserver.grpc.query.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,io.axoniq.axonserver.grpc.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)
Constructs a
GrpcObjectSerializer using the given serializer to serialize the payload and type of
given objects with. |
GrpcPayloadSerializer(Serializer serializer)
Constructs a
GrpcPayloadSerializer using the given serializer to serialize messages with |
| 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 containing 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 |
DefaultConfigurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder) |
Configurer |
Configurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
Configurer |
DefaultConfigurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder) |
Configurer |
Configurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder)
Configures the given event Serializer to use in this configuration.
|
default Configurer |
Configurer.configureSerializer(Function<Configuration,Serializer> serializerBuilder)
Configures the given Serializer to use in this configuration.
|
| Modifier and Type | Method and Description |
|---|---|
GenericDeadlineMessage |
DbSchedulerHumanReadableDeadlineDetails.asDeadLineMessage(Serializer serializer)
Returns the
DbSchedulerHumanReadableDeadlineDetails as an GenericDeadlineMessage, with the
timestamp set using the GenericEventMessage.clock. |
GenericDeadlineMessage |
DbSchedulerBinaryDeadlineDetails.asDeadLineMessage(Serializer serializer)
Returns the
DbSchedulerBinaryDeadlineDetails as an GenericDeadlineMessage, with the
timestamp set using the GenericEventMessage.clock. |
ScopeDescriptor |
DbSchedulerHumanReadableDeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer. |
ScopeDescriptor |
DbSchedulerBinaryDeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer. |
DbSchedulerDeadlineManager.Builder |
DbSchedulerDeadlineManager.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize the payload,
MetaData and the ScopeDescriptor into the DeadlineDetails
as well as the whole DeadlineDetails itself. |
| Modifier and Type | Method and Description |
|---|---|
GenericDeadlineMessage |
DeadlineDetails.asDeadLineMessage(Serializer serializer)
Returns the
DeadlineDetails as an GenericDeadlineMessage, with the timestamp set using
the GenericEventMessage.clock to set to the current time. |
static String |
LabelUtils.getCombinedLabel(Serializer serializer,
String deadlineName,
ScopeDescriptor scope)
Creates a label from a scope and a deadlineName, by using the serializer.
|
ScopeDescriptor |
DeadlineDetails.getDeserializedScopeDescriptor(Serializer serializer)
Returns the serialized
ScopeDescriptor using the supplied Serializer. |
JobRunrDeadlineManager.Builder |
JobRunrDeadlineManager.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize the payload,
MetaData and the ScopeDescriptor into the DeadlineDetails
as well as the whole DeadlineDetails itself. |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer to (de)serialize the events, metadata and diagnostics of the DeadLetter
when storing it to a database. |
DefaultDeadLetterStatementFactory.Builder<E> |
DefaultDeadLetterStatementFactory.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer to serialize the event payload,
MetaData, and diagnostics of the
DeadLetter when storing it to a database. |
DefaultDeadLetterJdbcConverter.Builder<E> |
DefaultDeadLetterJdbcConverter.Builder.eventSerializer(Serializer eventSerializer)
|
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.genericSerializer(Serializer genericSerializer)
Sets the
Serializer to (de)serialize the TrackingToken (if
present) of the event in the DeadLetter when storing it to the database. |
DefaultDeadLetterStatementFactory.Builder<E> |
DefaultDeadLetterStatementFactory.Builder.genericSerializer(Serializer genericSerializer)
Sets the
Serializer to serialize the TrackingToken of a TrackedEventMessage instance
in the DeadLetter when storing it to the database. |
DefaultDeadLetterJdbcConverter.Builder<E> |
DefaultDeadLetterJdbcConverter.Builder.genericSerializer(Serializer genericSerializer)
|
| Modifier and Type | Method and Description |
|---|---|
EventMessage<?> |
EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry,
Serializer eventSerializer,
Serializer genericSerializer) |
M |
DeadLetterJpaConverter.convert(DeadLetterEventEntry entry,
Serializer eventSerializer,
Serializer genericSerializer)
Converts a
DeadLetterEventEntry to a EventMessage implementation. |
DeadLetterEventEntry |
EventMessageDeadLetterJpaConverter.convert(EventMessage<?> message,
Serializer eventSerializer,
Serializer genericSerializer) |
DeadLetterEventEntry |
DeadLetterJpaConverter.convert(M message,
Serializer eventSerializer,
Serializer genericSerializer)
Converts an
EventMessage implementation to a DeadLetterEventEntry. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.eventSerializer(Serializer serializer)
Sets the
Serializer to (de)serialize the event payload,
event metadata, and diagnostics of the DeadLetter when storing it to the database. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.genericSerializer(Serializer serializer)
Sets the
Serializer to (de)serialize the tracking token of the event in
the DeadLetter when storing it to the database. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.serializer(Serializer serializer)
Sets the
Serializer to (de)serialize the event payload,
event metadata, tracking token, and diagnostics of the DeadLetter when storing it to the database. |
void |
DeadLetterEntry.setDiagnostics(MetaData diagnostics,
Serializer serializer)
Sets the diagnostics, taking in a
Serializer to serialize if to the correct format. |
| Constructor and Description |
|---|
DeadLetterEntry(String processingGroup,
String sequenceIdentifier,
long sequenceIndex,
DeadLetterEventEntry message,
Instant enqueuedAt,
Instant lastTouched,
Cause cause,
MetaData diagnostics,
Serializer serializer)
Creates a new
DeadLetterEntry consisting of the given parameters. |
| Modifier and Type | Method and Description |
|---|---|
EventMessage<?> |
EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry,
Serializer eventSerializer,
Serializer genericSerializer)
Deprecated.
|
M |
DeadLetterJpaConverter.convert(DeadLetterEventEntry entry,
Serializer eventSerializer,
Serializer genericSerializer)
Deprecated.
Converts a
DeadLetterEventEntry to a EventMessage implementation. |
DeadLetterEventEntry |
EventMessageDeadLetterJpaConverter.convert(EventMessage<?> message,
Serializer eventSerializer,
Serializer genericSerializer)
Deprecated.
|
DeadLetterEventEntry |
DeadLetterJpaConverter.convert(M message,
Serializer eventSerializer,
Serializer genericSerializer)
Deprecated.
Converts an
EventMessage implementation to a DeadLetterEventEntry. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.eventSerializer(Serializer serializer)
Sets the
Serializer to (de)serialize the event payload, event metadata, and diagnostics of the
DeadLetter when storing it to the database. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.genericSerializer(Serializer serializer)
Sets the
Serializer to (de)serialize the tracking token of the event in the DeadLetter when
storing it to the database. |
JpaSequencedDeadLetterQueue.Builder<T> |
JpaSequencedDeadLetterQueue.Builder.serializer(Serializer serializer)
Sets the
Serializer to deserialize the events, metadata and diagnostics of the DeadLetter
when storing it to a database. |
| Modifier and Type | Method and Description |
|---|---|
DbSchedulerEventScheduler.Builder |
DbSchedulerEventScheduler.Builder.serializer(Serializer serializer)
|
| Modifier and Type | Method and Description |
|---|---|
JobRunrEventScheduler.Builder |
JobRunrEventScheduler.Builder.serializer(Serializer serializer)
|
| Modifier and Type | Method and Description |
|---|---|
QuartzEventScheduler.Builder |
QuartzEventScheduler.Builder.serializer(Serializer serializer)
Sets the
Serializer used by the EventJobDataBinder. |
| 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 |
|---|---|
Serializer |
JdbcTokenStore.serializer()
Returns the serializer used by the Token Store to serialize tokens.
|
| 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 |
|---|---|
Serializer |
JpaTokenStore.serializer()
Returns the serializer used by the Token Store to serialize tokens.
|
| Modifier and Type | Method and Description |
|---|---|
TrackingToken |
TokenEntry.getToken(Serializer serializer)
Returns the token, deserializing it with given
serializer |
JpaTokenStore.Builder |
JpaTokenStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize TrackingTokens with. |
void |
TokenEntry.updateToken(TrackingToken token,
Serializer serializer)
Updates a token, using the provided token and serializer to update the serialized token and token type.
|
| 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 |
|---|---|
Serializer |
JpaTokenStore.serializer()
Deprecated.
Returns the serializer used by the Token Store to serialize tokens.
|
| Modifier and Type | Method and Description |
|---|---|
JpaTokenStore.Builder |
JpaTokenStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize TrackingTokens with. |
| 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. |
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer) |
AbstractEventStorageEngine.Builder |
AbstractEventStorageEngine.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer used to serialize and deserialize the Event Message's payload and MetaData with. |
BatchingEventStorageEngine.Builder |
BatchingEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer) |
AbstractEventStorageEngine.Builder |
AbstractEventStorageEngine.Builder.snapshotSerializer(Serializer snapshotSerializer)
Sets the
Serializer used to serialize and deserialize snapshots. |
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 PreparedStatement |
JdbcEventStorageEngine.appendEvents(Connection connection,
List<? extends EventMessage<?>> events,
Serializer serializer)
Creates a statement to be used at
JdbcEventStorageEngine.appendEvents(List, Serializer). |
protected void |
JdbcEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events,
Serializer serializer) |
protected PreparedStatement |
JdbcEventStorageEngine.appendSnapshot(Connection connection,
DomainEventMessage<?> snapshot,
Serializer serializer)
Creates a statement to be used at
AbstractEventStorageEngine.storeSnapshot(DomainEventMessage). |
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 |
|---|---|
static PreparedStatement |
JdbcEventStorageEngineStatements.appendEvents(Connection connection,
EventSchema schema,
Class<?> dataType,
List<? extends EventMessage<?>> events,
Serializer serializer,
TimestampWriter timestampWriter)
Set the PreparedStatement to be used on
JdbcEventStorageEngine.appendEvents(List, Serializer). |
static PreparedStatement |
JdbcEventStorageEngineStatements.appendSnapshot(Connection connection,
EventSchema schema,
Class<?> dataType,
DomainEventMessage<?> snapshot,
Serializer serializer,
TimestampWriter timestampWriter)
Set the PreparedStatement to be used on
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage,
Serializer) . |
PreparedStatement |
AppendSnapshotStatementBuilder.build(Connection connection,
EventSchema schema,
Class<?> dataType,
DomainEventMessage<?> snapshot,
Serializer serializer,
TimestampWriter timestampWriter)
Creates a statement to be used at
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer) |
PreparedStatement |
AppendEventsStatementBuilder.build(Connection connection,
EventSchema schema,
Class<?> dataType,
List<? extends EventMessage<?>> events,
Serializer serializer,
TimestampWriter timestampWriter)
Build a statement to be used at
JdbcEventStorageEngine.appendEvents(List, 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 |
|---|---|
protected void |
JpaEventStorageEngine.appendEvents(List<? extends EventMessage<?>> events,
Serializer serializer)
Deprecated.
|
protected Object |
JpaEventStorageEngine.createEventEntity(EventMessage<?> eventMessage,
Serializer serializer)
Deprecated.
Returns a Jpa event entity for given
eventMessage. |
protected Object |
JpaEventStorageEngine.createSnapshotEntity(DomainEventMessage<?> snapshot,
Serializer serializer)
Deprecated.
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)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
default <T> SerializedObject<T> |
ResultMessage.serializeExceptionResult(Serializer serializer,
Class<T> expectedRepresentation)
Serializes the exception result.
|
default <R> SerializedObject<R> |
Message.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the meta data of this message to the
expectedRepresentation using given serializer. |
<R> SerializedObject<R> |
GenericMessage.serializeMetaData(Serializer serializer,
Class<R> expectedRepresentation) |
<S> SerializedObject<S> |
MessageDecorator.serializeMetaData(Serializer serializer,
Class<S> expectedRepresentation) |
default <R> SerializedObject<R> |
Message.serializePayload(Serializer serializer,
Class<R> expectedRepresentation)
Serialize the payload of this message to the
expectedRepresentation using given serializer. |
<R> SerializedObject<R> |
GenericMessage.serializePayload(Serializer serializer,
Class<R> expectedRepresentation) |
default <S> SerializedObject<S> |
ResultMessage.serializePayload(Serializer serializer,
Class<S> expectedRepresentation) |
<S> SerializedObject<S> |
MessageDecorator.serializePayload(Serializer serializer,
Class<S> expectedRepresentation) |
<S> SerializedObject<S> |
GenericResultMessage.serializePayload(Serializer serializer,
Class<S> expectedRepresentation) |
| Modifier and Type | Method and Description |
|---|---|
<T> SerializedObject<T> |
ConvertingResponseMessage.serializeExceptionResult(Serializer serializer,
Class<T> expectedRepresentation) |
<R1> SerializedObject<R1> |
ConvertingResponseMessage.serializeMetaData(Serializer serializer,
Class<R1> expectedRepresentation) |
<S> SerializedObject<S> |
ConvertingResponseMessage.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 SagaEntry<?> |
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)
Deprecated.
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 | Method and Description |
|---|---|
protected SagaEntry<?> |
JpaSagaStore.createSagaEntry(Object saga,
String sagaIdentifier,
Serializer serializer)
Deprecated.
Intended for clients to override.
|
JpaSagaStore.Builder |
JpaSagaStore.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize a Saga instance. |
| 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 |
AvroSerializer
Serializer providing support for Apache Avro, using
Single Object Encoded binary
encoding.
|
| Modifier and Type | Method and Description |
|---|---|
AvroSerializer.Builder |
AvroSerializer.Builder.serializerDelegate(Serializer serializerDelegate)
Sets serializer delegate, used for all types which can't be converted to Avro.
|
| 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()
Deprecated.
|
Serializer |
AxonConfiguration.messageSerializer()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
QuartzEventSchedulerFactoryBean.setSerializer(Serializer serializer)
Sets the
Serializer used by the EventJobDataBinder. |
| Modifier and Type | Method and Description |
|---|---|
Serializer |
AxonAutoConfiguration.eventSerializer(Serializer messageSerializer,
Serializer generalSerializer,
RevisionResolver revisionResolver) |
Serializer |
AxonAutoConfiguration.messageSerializer(Serializer generalSerializer,
RevisionResolver revisionResolver) |
Serializer |
AxonAutoConfiguration.serializer(RevisionResolver revisionResolver) |
| Modifier and Type | Method and Description |
|---|---|
AxonServerCommandBus |
AxonServerBusAutoConfiguration.axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver,
CommandBusSpanFactory spanFactory) |
AxonServerEventStoreFactory |
AxonServerBusAutoConfiguration.axonServerEventStoreFactory(AxonServerConfiguration axonServerConfig,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer,
Configuration config) |
DeadLetterQueueProviderConfigurerModule |
JdbcAutoConfiguration.deadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties,
ConnectionProvider connectionProvider,
TransactionManager transactionManager,
DeadLetterSchema schema,
Serializer eventSerializer,
Serializer genericSerializer) |
DeadLetterQueueProviderConfigurerModule |
JpaAutoConfiguration.deadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager,
Serializer genericSerializer,
Serializer eventSerializer) |
DeadlineManager |
AxonJobRunrAutoConfiguration.deadlineManager(org.jobrunr.scheduling.JobScheduler jobScheduler,
Configuration configuration,
Serializer serializer,
TransactionManager transactionManager,
DeadlineManagerSpanFactory spanFactory) |
DeadlineManager |
AxonDbSchedulerAutoConfiguration.deadlineManager(com.github.kagkarlsson.scheduler.Scheduler scheduler,
Configuration configuration,
Serializer serializer,
TransactionManager transactionManager,
DeadlineManagerSpanFactory spanFactory) |
EventScheduler |
AxonJobRunrAutoConfiguration.eventScheduler(org.jobrunr.scheduling.JobScheduler jobScheduler,
Serializer serializer,
TransactionManager transactionManager,
EventBus eventBus) |
EventScheduler |
AxonDbSchedulerAutoConfiguration.eventScheduler(com.github.kagkarlsson.scheduler.Scheduler scheduler,
Serializer serializer,
TransactionManager transactionManager,
EventBus eventBus) |
EventScheduler |
AxonServerAutoConfiguration.eventScheduler(Serializer eventSerializer,
AxonServerConnectionManager connectionManager) |
Serializer |
AxonAutoConfiguration.eventSerializer(Serializer messageSerializer,
Serializer generalSerializer,
RevisionResolver revisionResolver) |
EventStorageEngine |
JdbcAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
ConnectionProvider connectionProvider,
TransactionManager transactionManager,
EventSchema eventSchema) |
EventStorageEngine |
JpaEventStoreAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager) |
EventStore |
AxonServerBusAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
Configuration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
Serializer |
AxonAutoConfiguration.messageSerializer(Serializer generalSerializer,
RevisionResolver revisionResolver) |
AxonServerQueryBus |
AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
Configuration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
JpaSagaStore |
JpaAutoConfiguration.sagaStore(Serializer serializer,
EntityManagerProvider entityManagerProvider) |
JdbcSagaStore |
JdbcAutoConfiguration.sagaStoreNoSchema(ConnectionProvider connectionProvider,
Serializer serializer) |
JdbcSagaStore |
JdbcAutoConfiguration.sagaStoreWithSchema(ConnectionProvider connectionProvider,
Serializer serializer,
SagaSqlSchema schema) |
ConfigurerModule |
AxonAutoConfiguration.serializerConfigurer(Serializer eventSerializer,
Serializer messageSerializer,
Serializer generalSerializer) |
TokenStore |
JdbcAutoConfiguration.tokenStore(ConnectionProvider connectionProvider,
Serializer serializer,
TokenSchema tokenSchema) |
TokenStore |
JpaAutoConfiguration.tokenStore(Serializer serializer,
EntityManagerProvider entityManagerProvider) |
| Modifier and Type | Method and Description |
|---|---|
DeadLetterQueueProviderConfigurerModule |
JpaJavaxAutoConfiguration.deadLetterQueueProviderConfigurerModule(EventProcessorProperties eventProcessorProperties,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager,
Serializer genericSerializer,
Serializer eventSerializer)
Deprecated.
|
EventStorageEngine |
JpaJavaxEventStoreAutoConfiguration.eventStorageEngine(Serializer defaultSerializer,
PersistenceExceptionResolver persistenceExceptionResolver,
Serializer eventSerializer,
Configuration configuration,
EntityManagerProvider entityManagerProvider,
TransactionManager transactionManager)
Deprecated.
|
JpaSagaStore |
JpaJavaxAutoConfiguration.sagaStore(Serializer serializer,
EntityManagerProvider entityManagerProvider)
Deprecated.
|
TokenStore |
JpaJavaxAutoConfiguration.tokenStore(Serializer serializer,
EntityManagerProvider entityManagerProvider)
Deprecated.
|
Copyright © 2010–2025. All rights reserved.