public class SubscriptionMessageSerializer extends Object
SubscriptionQueryMessage, the initial QueryResponseMessage and the
subsequent SubscriptionQueryUpdateMessage's and Axon Server gRPC SubscriptionQuery and SubscriptionQueryResponse. The latter is serviced by providing a QueryProviderOutbound wrapping the
SubscriptionQueryResponse.| Constructor and Description |
|---|
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. |
| Modifier and Type | Method and Description |
|---|---|
SubscriptionQuery |
serialize(SubscriptionQueryMessage subscriptionQueryMessage)
Convert a
SubscriptionQueryMessage into a SubscriptionQuery. |
public SubscriptionMessageSerializer(Serializer messageSerializer, Serializer serializer, AxonServerConfiguration configuration)
SubscriptionQueryMessages, the initial
QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessages into Axon Server gRPC
messages and vice versa.messageSerializer - a Serializer used to de-/serialize an Axon Server gRPC message into
SubscriptionQueryMessages, QueryResponseMessages and
SubscriptionQueryUpdateMessages, and vice versaserializer - a Serializer used to create a dedicated converter for a QueryMessage
ResponseTypeconfiguration - an AxonServerConfiguration used to set the configurable component id and name in
the messagespublic SubscriptionQuery serialize(SubscriptionQueryMessage subscriptionQueryMessage)
SubscriptionQueryMessage into a SubscriptionQuery.subscriptionQueryMessage - the SubscriptionQueryMessage to convert into a SubscriptionQuerySubscriptionQuery based on the provided subscriptionQueryMessageCopyright © 2010–2020. All rights reserved.