Package org.axonframework.axonserver.connector.query

Class GrpcBackedQueryMessage<Q,R>

java.lang.Object

org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage<Q,R>

Type Parameters:

Q - a generic specifying the type of the QueryMessage's payload

R - a generic specifying the expected response type of the QueryMessage

All Implemented Interfaces:

Serializable, org.axonframework.messaging.Message<Q>, org.axonframework.queryhandling.QueryMessage<Q,R>

public class GrpcBackedQueryMessage<Q,R>
extends Object
implements org.axonframework.queryhandling.QueryMessage<Q,R>

Wrapper that allows clients to access a gRPC QueryRequest as a QueryMessage.

Since:

4.0

Author:

Marc Gathier

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
GrpcBackedQueryMessage(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest, org.axonframework.serialization.Serializer messageSerializer, org.axonframework.serialization.Serializer serializer)	Instantiate a GrpcBackedResponseMessage with the given queryRequest, using the provided messageSerializer to be able to retrieve the payload and MetaData from it.

Method Summary

Modifier and Type	Method	Description
GrpcBackedQueryMessage<Q,R>	andMetaData(Map<String,?> metaData)
String	getIdentifier()
org.axonframework.messaging.MetaData	getMetaData()
Q	getPayload()
Class<Q>	getPayloadType()
String	getQueryName()
org.axonframework.messaging.responsetypes.ResponseType<R>	getResponseType()
GrpcBackedQueryMessage<Q,R>	withMetaData(Map<String,?> metaData)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.messaging.Message

serializeMetaData, serializePayload

Constructor Details

GrpcBackedQueryMessage

public GrpcBackedQueryMessage(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest,
 org.axonframework.serialization.Serializer messageSerializer,
 org.axonframework.serialization.Serializer serializer)

Instantiate a GrpcBackedResponseMessage with the given queryRequest, using the provided messageSerializer to be able to retrieve the payload and MetaData from it. The serializer is solely used to deserialize the response type.

Parameters:

queryRequest - the QueryRequest which is being wrapped as a QueryMessage

messageSerializer - the Serializer used to deserialize the payload and MetaData from the given queryRequest

serializer - the Serializer used to deserialize the response type

Method Details

getQueryName

public String getQueryName()

Specified by:

getQueryName in interface org.axonframework.queryhandling.QueryMessage<Q,R>

getResponseType

public org.axonframework.messaging.responsetypes.ResponseType<R> getResponseType()

Specified by:

getResponseType in interface org.axonframework.queryhandling.QueryMessage<Q,R>

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface org.axonframework.messaging.Message<Q>

getMetaData

public org.axonframework.messaging.MetaData getMetaData()

Specified by:

getMetaData in interface org.axonframework.messaging.Message<Q>

getPayload

public Q getPayload()

Specified by:

getPayload in interface org.axonframework.messaging.Message<Q>

getPayloadType

public Class<Q> getPayloadType()

Specified by:

getPayloadType in interface org.axonframework.messaging.Message<Q>

withMetaData

public GrpcBackedQueryMessage<Q,R> withMetaData(@Nonnull
 Map<String,?> metaData)

Specified by:

withMetaData in interface org.axonframework.messaging.Message<Q>

Specified by:

withMetaData in interface org.axonframework.queryhandling.QueryMessage<Q,R>

andMetaData

public GrpcBackedQueryMessage<Q,R> andMetaData(@Nonnull
 Map<String,?> metaData)

Specified by:

andMetaData in interface org.axonframework.messaging.Message<Q>

Specified by:

andMetaData in interface org.axonframework.queryhandling.QueryMessage<Q,R>