@Test void testGetIdentifierReturnsTheSameIdentifierAsSpecifiedInTheSubscriptionQuery() { SubscriptionQueryMessage testSubscriptionQueryMessage = new GenericSubscriptionQueryMessage<>(TEST_QUERY, RESPONSE_TYPE, RESPONSE_TYPE); SubscriptionQuery testSubscriptionQuery = subscriptionMessageSerializer.serialize(testSubscriptionQueryMessage); GrpcBackedSubscriptionQueryMessage<TestQuery, String, String> testSubject = new GrpcBackedSubscriptionQueryMessage<>(testSubscriptionQuery, serializer, serializer); assertEquals(testSubscriptionQuery.getSubscriptionIdentifier(), testSubject.getIdentifier()); }
@Override public String getIdentifier() { return subscriptionQuery.getSubscriptionIdentifier(); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public String getIdentifier() { return subscriptionQuery.getSubscriptionIdentifier(); } }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public String getIdentifier() { return subscriptionQuery.getSubscriptionIdentifier(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public String getIdentifier() { return subscriptionQuery.getSubscriptionIdentifier(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); @Override ResponseType<U> getUpdateResponseType(); @Override String getQueryName(); @Override ResponseType<I> getResponseType(); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override Q getPayload(); @Override Class<Q> getPayloadType(); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> andMetaData(Map<String, ?> metaData); }
GrpcBackedSubscriptionQueryMessage implements SubscriptionQueryMessage<Q, I, U> { @Override public String getIdentifier() { return subscriptionQuery.getSubscriptionIdentifier(); } GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                              Serializer messageSerializer,
                                              Serializer serializer); private  GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery,
                                               GrpcBackedQueryMessage<Q, I> grpcBackedQueryMessage,
                                               LazyDeserializingObject<ResponseType<U>> serializedUpdateResponseType); @Override ResponseType<U> getUpdateResponseType(); @Override String getQueryName(); @Override ResponseType<I> getResponseType(); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override Q getPayload(); @Override Class<Q> getPayloadType(); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedSubscriptionQueryMessage<Q, I, U> andMetaData(Map<String, ?> metaData);  }