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
CommandMessage s and CommandResultMessage s 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 |
---|---|
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. |
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
QueryMessage s and QueryResponseMessage s 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
SubscriptionQueryMessage s, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage s 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 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 |
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 |
---|---|
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 |
---|---|
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 TrackingToken s 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 |
---|---|
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. |
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 |
---|---|
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 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(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver) |
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,
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,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
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–2022. All rights reserved.