Uses of Class
io.axoniq.axonserver.grpc.query.QueryResponse
-
Packages that use QueryResponse Package Description io.axoniq.axonserver.connector.query io.axoniq.axonserver.connector.query.impl io.axoniq.axonserver.grpc.query -
-
Uses of QueryResponse in io.axoniq.axonserver.connector.query
Methods in io.axoniq.axonserver.connector.query that return types with arguments of type QueryResponse Modifier and Type Method Description CompletableFuture<QueryResponse>SubscriptionQueryResult. initialResult()Deprecated, for removal: This API element is subject to removal in a future version.in favor ofSubscriptionQueryResult.initialResults(), which returns a stream of results.ResultStream<QueryResponse>SubscriptionQueryResult. initialResults()Returns a ResultStream that represent the initial result of the subscription query.ResultStream<QueryResponse>QueryChannel. query(QueryRequest query)Sends the givenqueryto AxonServer for routing to the appropriate handlers.Method parameters in io.axoniq.axonserver.connector.query with type arguments of type QueryResponse Modifier and Type Method Description voidQueryHandler. handle(QueryRequest query, ReplyChannel<QueryResponse> responseHandler)Handle the givenquery, using givenresponseHandlerto send the response(s).default FlowControlQueryHandler. stream(QueryRequest query, ReplyChannel<QueryResponse> responseHandler)Handle the givenquery, using the givenresponseHandlerto send the response(s). -
Uses of QueryResponse in io.axoniq.axonserver.connector.query.impl
Methods in io.axoniq.axonserver.connector.query.impl that return types with arguments of type QueryResponse Modifier and Type Method Description ResultStream<QueryResponse>SubscriptionQueryStream. initialStream()Returns theResultStreambuffering the initial results to this subscription query.ResultStream<QueryResponse>QueryChannelImpl. query(QueryRequest query)Constructor parameters in io.axoniq.axonserver.connector.query.impl with type arguments of type QueryResponse Constructor Description SubscriptionQueryStream(String subscriptionQueryId, CompletableFuture<QueryResponse> initialResultFuture, String clientId, Supplier<ResultStream<QueryResponse>> initialResultSupplier, int bufferSize, int fetchSize)Instantiates aSubscriptionQueryStreamto streamSubscriptionQueryresults.SubscriptionQueryStream(String subscriptionQueryId, CompletableFuture<QueryResponse> initialResultFuture, String clientId, Supplier<ResultStream<QueryResponse>> initialResultSupplier, int bufferSize, int fetchSize)Instantiates aSubscriptionQueryStreamto streamSubscriptionQueryresults. -
Uses of QueryResponse in io.axoniq.axonserver.grpc.query
Methods in io.axoniq.axonserver.grpc.query that return QueryResponse Modifier and Type Method Description QueryResponseQueryResponse.Builder. build()QueryResponseQueryResponse.Builder. buildPartial()static QueryResponseQueryResponse. getDefaultInstance()QueryResponseQueryResponse.Builder. getDefaultInstanceForType()QueryResponseQueryResponse. getDefaultInstanceForType()QueryResponseSubscriptionQueryResponse.Builder. getInitialResult()Provides an Initial ResponseQueryResponseSubscriptionQueryResponse. getInitialResult()Provides an Initial ResponseQueryResponseSubscriptionQueryResponseOrBuilder. getInitialResult()Provides an Initial ResponseQueryResponseQueryProviderOutbound.Builder. getQueryResponse()Sends a Response to a Query received via the inbound streamQueryResponseQueryProviderOutbound. getQueryResponse()Sends a Response to a Query received via the inbound streamQueryResponseQueryProviderOutboundOrBuilder. getQueryResponse()Sends a Response to a Query received via the inbound streamstatic QueryResponseQueryResponse. parseDelimitedFrom(InputStream input)static QueryResponseQueryResponse. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryResponseQueryResponse. parseFrom(byte[] data)static QueryResponseQueryResponse. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryResponseQueryResponse. parseFrom(com.google.protobuf.ByteString data)static QueryResponseQueryResponse. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryResponseQueryResponse. parseFrom(com.google.protobuf.CodedInputStream input)static QueryResponseQueryResponse. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryResponseQueryResponse. parseFrom(InputStream input)static QueryResponseQueryResponse. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static QueryResponseQueryResponse. parseFrom(ByteBuffer data)static QueryResponseQueryResponse. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type QueryResponse Modifier and Type Method Description com.google.protobuf.Parser<QueryResponse>QueryResponse. getParserForType()static io.grpc.MethodDescriptor<QueryRequest,QueryResponse>QueryServiceGrpc. getQueryMethod()static com.google.protobuf.Parser<QueryResponse>QueryResponse. parser()Iterator<QueryResponse>QueryServiceGrpc.QueryServiceBlockingStub. query(QueryRequest request)Sends a point-to-point or scatter-gather Queryio.grpc.stub.BlockingClientCall<?,QueryResponse>QueryServiceGrpc.QueryServiceBlockingV2Stub. query(QueryRequest request)Sends a point-to-point or scatter-gather QueryMethods in io.axoniq.axonserver.grpc.query with parameters of type QueryResponse Modifier and Type Method Description QueryResponse.BuilderQueryResponse.Builder. mergeFrom(QueryResponse other)SubscriptionQueryResponse.BuilderSubscriptionQueryResponse.Builder. mergeInitialResult(QueryResponse value)Provides an Initial ResponseQueryProviderOutbound.BuilderQueryProviderOutbound.Builder. mergeQueryResponse(QueryResponse value)Sends a Response to a Query received via the inbound streamstatic QueryResponse.BuilderQueryResponse. newBuilder(QueryResponse prototype)SubscriptionQueryResponse.BuilderSubscriptionQueryResponse.Builder. setInitialResult(QueryResponse value)Provides an Initial ResponseQueryProviderOutbound.BuilderQueryProviderOutbound.Builder. setQueryResponse(QueryResponse value)Sends a Response to a Query received via the inbound streamMethod parameters in io.axoniq.axonserver.grpc.query with type arguments of type QueryResponse Modifier and Type Method Description default voidQueryServiceGrpc.AsyncService. query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)Sends a point-to-point or scatter-gather QueryvoidQueryServiceGrpc.QueryServiceStub. query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)Sends a point-to-point or scatter-gather Query
-