org.axonframework.axonserver.connector.query

Class QuerySerializer

java.lang.Object

org.axonframework.axonserver.connector.query.QuerySerializer

public class QuerySerializer
extends Object

Converter between Axon QueryRequest/QueryResponse and AxonServer GRPC messages.

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
QuerySerializer(Serializer messageSerializer, Serializer genericSerializer, AxonServerConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
<Q,R> QueryMessage<Q,R>	deserializeRequest(QueryRequest query)
<R> QueryResponseMessage<R>	deserializeResponse(QueryResponse commandResponse)
<Q,R> QueryRequest	serializeRequest(QueryMessage<Q,R> queryMessage, int nrResults, long timeout, int priority)
QueryResponse	serializeResponse(QueryResponseMessage<?> response, String requestMessageId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QuerySerializer

public QuerySerializer(Serializer messageSerializer,
                       Serializer genericSerializer,
                       AxonServerConfiguration configuration)

Method Detail

deserializeRequest

public <Q,R> QueryMessage<Q,R> deserializeRequest(QueryRequest query)

serializeResponse

public QueryResponse serializeResponse(QueryResponseMessage<?> response,
                                       String requestMessageId)

serializeRequest

public <Q,R> QueryRequest serializeRequest(QueryMessage<Q,R> queryMessage,
                                           int nrResults,
                                           long timeout,
                                           int priority)

deserializeResponse

public <R> QueryResponseMessage<R> deserializeResponse(QueryResponse commandResponse)