@Test void testComplete() { QueryProviderOutbound grpcMessage = testSubject.serializeComplete("subscriptionId"); assertEquals("subscriptionId", grpcMessage.getSubscriptionQueryResponse().getSubscriptionIdentifier()); }
@Deprecated QueryProviderOutbound serializeComplete(String subscriptionId) { QueryUpdateComplete completedQueryUpdate = QueryUpdateComplete.newBuilder() .setClientId(configuration.getClientId()) .setComponentName(configuration.getComponentName()) .build(); return newBuilder().setSubscriptionQueryResponse( SubscriptionQueryResponse.newBuilder() .setSubscriptionIdentifier(subscriptionId) .setComplete(completedQueryUpdate) ).build(); }
SubscriptionMessageSerializer { @Deprecated QueryProviderOutbound serializeComplete(String subscriptionId) { QueryUpdateComplete completedQueryUpdate = QueryUpdateComplete.newBuilder() .setClientId(configuration.getClientId()) .setComponentName(configuration.getComponentName()) .build(); return newBuilder().setSubscriptionQueryResponse( SubscriptionQueryResponse.newBuilder() .setSubscriptionIdentifier(subscriptionId) .setComplete(completedQueryUpdate) ).build(); } }
SubscriptionMessageSerializer { @Deprecated QueryProviderOutbound serializeComplete(String subscriptionId) { QueryUpdateComplete completedQueryUpdate = QueryUpdateComplete.newBuilder() .setClientId(configuration.getClientId()) .setComponentName(configuration.getComponentName()) .build(); return newBuilder().setSubscriptionQueryResponse( SubscriptionQueryResponse.newBuilder() .setSubscriptionIdentifier(subscriptionId) .setComplete(completedQueryUpdate) ).build(); } SubscriptionMessageSerializer(Serializer messageSerializer,
                                         Serializer serializer,
                                         AxonServerConfiguration configuration); }
SubscriptionMessageSerializer { @Deprecated QueryProviderOutbound serializeComplete(String subscriptionId) { QueryUpdateComplete completedQueryUpdate = QueryUpdateComplete.newBuilder() .setClientId(configuration.getClientId()) .setComponentName(configuration.getComponentName()) .build(); return newBuilder().setSubscriptionQueryResponse( SubscriptionQueryResponse.newBuilder() .setSubscriptionIdentifier(subscriptionId) .setComplete(completedQueryUpdate) ).build(); } SubscriptionMessageSerializer(Serializer messageSerializer,
                                         Serializer serializer,
                                         AxonServerConfiguration configuration); QueryRequest serializeQuery(SubscriptionQueryMessage subscriptionQueryMessage); SerializedObject serializeUpdateType(SubscriptionQueryMessage<?, ?, ?> subscriptionQueryMessage); QueryUpdate serialize(SubscriptionQueryUpdateMessage<?> subscriptionQueryUpdateMessage); SubscriptionQueryMessage<Q, I, U> deserialize(SubscriptionQuery subscriptionQuery); QueryResponseMessage<I> deserialize(QueryResponse queryResponse); SubscriptionQueryUpdateMessage<U> deserialize(QueryUpdate queryUpdate); @Deprecated SubscriptionQuery serialize(SubscriptionQueryMessage<?, ?, ?> subscriptionQueryMessage); }
SubscriptionMessageSerializer { @Deprecated QueryProviderOutbound serializeComplete(String subscriptionId) { QueryUpdateComplete completedQueryUpdate = QueryUpdateComplete.newBuilder() .setClientId(configuration.getClientId()) .setComponentName(configuration.getComponentName()) .build(); return newBuilder().setSubscriptionQueryResponse( SubscriptionQueryResponse.newBuilder() .setSubscriptionIdentifier(subscriptionId) .setComplete(completedQueryUpdate) ).build(); } SubscriptionMessageSerializer(Serializer messageSerializer,
                                         Serializer serializer,
                                         AxonServerConfiguration configuration); QueryRequest serializeQuery(SubscriptionQueryMessage subscriptionQueryMessage); SerializedObject serializeUpdateType(SubscriptionQueryMessage<?, ?, ?> subscriptionQueryMessage); QueryUpdate serialize(SubscriptionQueryUpdateMessage<?> subscriptionQueryUpdateMessage); SubscriptionQueryMessage<Q, I, U> deserialize(SubscriptionQuery subscriptionQuery); QueryResponseMessage<I> deserialize(QueryResponse queryResponse); SubscriptionQueryUpdateMessage<U> deserialize(QueryUpdate queryUpdate); @Deprecated SubscriptionQuery serialize(SubscriptionQueryMessage<?, ?, ?> subscriptionQueryMessage);  }