@Test void testGetIdentifierReturnsTheSameIdentifierAsSpecifiedInTheQueryUpdate() { SubscriptionQueryUpdateMessage<Object> testSubscriptionQueryUpdateMessage = GenericSubscriptionQueryUpdateMessage.asUpdateMessage(TEST_QUERY_UPDATE); QueryUpdate testQueryUpdate = subscriptionMessageSerializer.serialize(testSubscriptionQueryUpdateMessage); GrpcBackedQueryUpdateMessage<TestQueryUpdate> testSubject = new GrpcBackedQueryUpdateMessage<>(testQueryUpdate, serializer); assertEquals(testQueryUpdate.getMessageIdentifier(), testSubject.getIdentifier()); }
@Override public String getIdentifier() { return queryUpdate.getMessageIdentifier(); }
GrpcBackedQueryUpdateMessage implements SubscriptionQueryUpdateMessage<U> { @Override public String getIdentifier() { return queryUpdate.getMessageIdentifier(); } }
GrpcBackedQueryUpdateMessage implements SubscriptionQueryUpdateMessage<U> { @Override public String getIdentifier() { return queryUpdate.getMessageIdentifier(); } GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate, Serializer serializer); private  GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate,
                                         LazyDeserializingObject<U> serializedPayload,
                                         Throwable exception,
                                         Supplier<MetaData> metaDataSupplier); }
GrpcBackedQueryUpdateMessage implements SubscriptionQueryUpdateMessage<U> { @Override public String getIdentifier() { return queryUpdate.getMessageIdentifier(); } GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate, Serializer serializer); private  GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate,
                                         LazyDeserializingObject<U> serializedPayload,
                                         Throwable exception,
                                         Supplier<MetaData> metaDataSupplier); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override U getPayload(); @Override Class<U> getPayloadType(); @Override boolean isExceptional(); @Override Optional<Throwable> optionalExceptionResult(); @Override GrpcBackedQueryUpdateMessage<U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedQueryUpdateMessage<U> andMetaData(Map<String, ?> metaData); }
GrpcBackedQueryUpdateMessage implements SubscriptionQueryUpdateMessage<U> { @Override public String getIdentifier() { return queryUpdate.getMessageIdentifier(); } GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate, Serializer serializer); private  GrpcBackedQueryUpdateMessage(QueryUpdate queryUpdate,
                                         LazyDeserializingObject<U> serializedPayload,
                                         Throwable exception,
                                         Supplier<MetaData> metaDataSupplier); @Override String getIdentifier(); @Override MetaData getMetaData(); @Override U getPayload(); @Override Class<U> getPayloadType(); @Override boolean isExceptional(); @Override Optional<Throwable> optionalExceptionResult(); @Override GrpcBackedQueryUpdateMessage<U> withMetaData(Map<String, ?> metaData); @Override GrpcBackedQueryUpdateMessage<U> andMetaData(Map<String, ?> metaData);  }