@Test void testGetPayloadTypeReturnsTheTypeOfTheInsertedQueryResponseMessage() { QueryResponseMessage<TestQueryResponse> testQueryResponseMessage = GenericQueryResponseMessage.asResponseMessage(TEST_QUERY_RESPONSE); QueryResponse testQueryResponse = querySerializer.serializeResponse(testQueryResponseMessage, REQUEST_MESSAGE_ID); GrpcBackedResponseMessage<TestQueryResponse> testSubject = new GrpcBackedResponseMessage<>(testQueryResponse, serializer); assertEquals(TestQueryResponse.class, testSubject.getPayloadType()); }
@Override public Class<R> getPayloadType() { return serializedPayload == null ? null : serializedPayload.getType(); }
GrpcBackedResponseMessage implements QueryResponseMessage<R> { @Override public Class<R> getPayloadType() { return serializedPayload == null ? null : serializedPayload.getType(); } }
GrpcBackedResponseMessage implements QueryResponseMessage<R> { @Override public Class<R> getPayloadType() { return serializedPayload == null ? null : serializedPayload.getType(); } GrpcBackedResponseMessage(QueryResponse queryResponse, Serializer serializer); private  GrpcBackedResponseMessage(QueryResponse queryResponse,
                                      LazyDeserializingObject<R> serializedPayload,
                                      Throwable exception,
                                      Supplier<MetaData> metaDataSupplier); }
GrpcBackedResponseMessage implements QueryResponseMessage<R> { @Override public Class<R> getPayloadType() { return serializedPayload == null ? null : serializedPayload.getType(); } GrpcBackedResponseMessage(QueryResponse queryResponse, Serializer serializer); private  GrpcBackedResponseMessage(QueryResponse queryResponse,
                                      LazyDeserializingObject<R> serializedPayload,
                                      Throwable exception,
                                      Supplier<MetaData> metaDataSupplier); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override R getPayload(); @Override Class<R> getPayloadType(); @Override boolean isExceptional(); @Override Optional<Throwable> optionalExceptionResult(); @Override GrpcBackedResponseMessage<R> withMetaData(Map<String, ?> metaData); @Override GrpcBackedResponseMessage<R> andMetaData(Map<String, ?> metaData); }
GrpcBackedResponseMessage implements QueryResponseMessage<R> { @Override public Class<R> getPayloadType() { return serializedPayload == null ? null : serializedPayload.getType(); } GrpcBackedResponseMessage(QueryResponse queryResponse, Serializer serializer); private  GrpcBackedResponseMessage(QueryResponse queryResponse,
                                      LazyDeserializingObject<R> serializedPayload,
                                      Throwable exception,
                                      Supplier<MetaData> metaDataSupplier); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override R getPayload(); @Override Class<R> getPayloadType(); @Override boolean isExceptional(); @Override Optional<Throwable> optionalExceptionResult(); @Override GrpcBackedResponseMessage<R> withMetaData(Map<String, ?> metaData); @Override GrpcBackedResponseMessage<R> andMetaData(Map<String, ?> metaData);  }