Package org.axonframework.axonserver.connector.query

Class GrpcBackedResponseMessage<R>

java.lang.Object

org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage<R>

Type Parameters:

R - a generic specifying the type of the QueryResponseMessage

All Implemented Interfaces:

Serializable, org.axonframework.messaging.Message<R>, org.axonframework.messaging.ResultMessage<R>, org.axonframework.queryhandling.QueryResponseMessage<R>

public class GrpcBackedResponseMessage<R>
extends Object
implements org.axonframework.queryhandling.QueryResponseMessage<R>

Wrapper that allows clients to access a gRPC QueryResponse as a QueryResponseMessage.

Since:

4.0

Author:

Marc Gathier

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
GrpcBackedResponseMessage<R>	andMetaData(Map<String,?> metaData)
String	getIdentifier()
org.axonframework.messaging.MetaData	getMetaData()
R	getPayload()
Class<R>	getPayloadType()
boolean	isExceptional()
Optional<Throwable>	optionalExceptionResult()
GrpcBackedResponseMessage<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

Methods inherited from interface org.axonframework.messaging.ResultMessage

exceptionDetails, exceptionResult, serializeExceptionResult, serializePayload

Constructor Details

GrpcBackedResponseMessage

public GrpcBackedResponseMessage(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse,
 org.axonframework.serialization.Serializer serializer)

Instantiate a GrpcBackedResponseMessage with the given queryResponse, using the provided Serializer to be able to retrieve the payload and MetaData from it.

Parameters:

queryResponse - the QueryResponse which is being wrapped as a QueryResponseMessage

serializer - the Serializer used to deserialize the payload and MetaData from the given queryResponse

Method Details

getIdentifier

public String getIdentifier()

Specified by:

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

getMetaData

public org.axonframework.messaging.MetaData getMetaData()

Specified by:

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

getPayload

public R getPayload()

Specified by:

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

getPayloadType

public Class<R> getPayloadType()

Specified by:

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

isExceptional

public boolean isExceptional()

Specified by:

isExceptional in interface org.axonframework.messaging.ResultMessage<R>

optionalExceptionResult

public Optional<Throwable> optionalExceptionResult()

Specified by:

optionalExceptionResult in interface org.axonframework.messaging.ResultMessage<R>

withMetaData

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

Specified by:

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

Specified by:

withMetaData in interface org.axonframework.queryhandling.QueryResponseMessage<R>

Specified by:

withMetaData in interface org.axonframework.messaging.ResultMessage<R>

andMetaData

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

Specified by:

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

Specified by:

andMetaData in interface org.axonframework.queryhandling.QueryResponseMessage<R>

Specified by:

andMetaData in interface org.axonframework.messaging.ResultMessage<R>