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
SubscriptionQueryMessage s, the initial
QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage s 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)
SubscriptionQueryMessage
s, the initial
QueryResponseMessage
and the subsequent SubscriptionQueryUpdateMessage
s into Axon Server gRPC
messages and vice versa.messageSerializer
- a Serializer
used to de-/serialize an Axon Server gRPC message into
SubscriptionQueryMessage
s, QueryResponseMessage
s and
SubscriptionQueryUpdateMessage
s, and vice versaserializer
- a Serializer
used to create a dedicated converter for a QueryMessage
ResponseType
configuration
- 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 SubscriptionQuery
SubscriptionQuery
based on the provided subscriptionQueryMessage
Copyright © 2010–2019. All rights reserved.