Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.query

Interface QueryServiceGrpc.AsyncService

All Known Implementing Classes:

QueryServiceGrpc.QueryServiceImplBase

Enclosing class:

QueryServiceGrpc

public static interface QueryServiceGrpc.AsyncService

 Service providing operations for the Query Messaging component of AxonServer 
 

Method Summary

Modifier and Type	Method	Description
default io.grpc.stub.StreamObserver<QueryProviderOutbound>	openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver)	Opens a Query- and Instruction stream to AxonServer.
default void	query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)	Sends a point-to-point or scatter-gather Query
default io.grpc.stub.StreamObserver<SubscriptionQueryRequest>	subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)	Opens a Subscription Query

Method Detail

openStream

default io.grpc.stub.StreamObserver<QueryProviderOutbound> openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver)

 Opens a Query- and Instruction stream to AxonServer. 
 

query

default void query(QueryRequest request,
                   io.grpc.stub.StreamObserver<QueryResponse> responseObserver)

 Sends a point-to-point or scatter-gather Query 
 

subscription

default io.grpc.stub.StreamObserver<SubscriptionQueryRequest> subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)

 Opens a Subscription Query