public static final class QueryServiceGrpc.QueryServiceStub extends io.grpc.stub.AbstractStub<QueryServiceGrpc.QueryServiceStub>
Service providing operations for the Query Messaging component of AxonServer
Modifier and Type | Method and Description |
---|---|
protected QueryServiceGrpc.QueryServiceStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
io.grpc.stub.StreamObserver<QueryProviderOutbound> |
openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver)
Opens a Query- and Instruction stream to AxonServer.
|
void |
query(QueryRequest request,
io.grpc.stub.StreamObserver<QueryResponse> responseObserver)
Sends a point-to-point or scatter-gather Query
|
io.grpc.stub.StreamObserver<SubscriptionQueryRequest> |
subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)
Opens a Subscription Query
|
protected QueryServiceGrpc.QueryServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<QueryServiceGrpc.QueryServiceStub>
public io.grpc.stub.StreamObserver<QueryProviderOutbound> openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver)
Opens a Query- and Instruction stream to AxonServer.
public void query(QueryRequest request, io.grpc.stub.StreamObserver<QueryResponse> responseObserver)
Sends a point-to-point or scatter-gather Query
public io.grpc.stub.StreamObserver<SubscriptionQueryRequest> subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)
Opens a Subscription Query
Copyright © 2010–2020. All rights reserved.