Uses of Class
io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest

Packages that use SubscriptionQueryRequest

Package	Description
io.axoniq.axonserver.connector.query.impl
io.axoniq.axonserver.grpc.query

Uses of SubscriptionQueryRequest in io.axoniq.axonserver.connector.query.impl

Methods in io.axoniq.axonserver.connector.query.impl that return SubscriptionQueryRequest

Modifier and Type	Method	Description
protected SubscriptionQueryRequest	SubscriptionQueryStream.buildFlowControlMessage(FlowControl flowControl)
protected SubscriptionQueryRequest	SubscriptionQueryUpdateBuffer.buildFlowControlMessage(FlowControl flowControl)

Method parameters in io.axoniq.axonserver.connector.query.impl with type arguments of type SubscriptionQueryRequest

Modifier and Type	Method	Description
void	SubscriptionQueryStream.beforeStart(io.grpc.stub.ClientCallStreamObserver<SubscriptionQueryRequest> requestStream)

Uses of SubscriptionQueryRequest in io.axoniq.axonserver.grpc.query

Methods in io.axoniq.axonserver.grpc.query that return SubscriptionQueryRequest

Modifier and Type	Method	Description
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.build()
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.buildPartial()
static SubscriptionQueryRequest	SubscriptionQueryRequest.getDefaultInstance()
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.getDefaultInstanceForType()
SubscriptionQueryRequest	SubscriptionQueryRequest.getDefaultInstanceForType()
SubscriptionQueryRequest	QueryProviderInbound.Builder.getSubscriptionQueryRequest()	Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
SubscriptionQueryRequest	QueryProviderInbound.getSubscriptionQueryRequest()	Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
SubscriptionQueryRequest	QueryProviderInboundOrBuilder.getSubscriptionQueryRequest()	Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseDelimitedFrom(InputStream input)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(byte[] data)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(com.google.protobuf.ByteString data)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(com.google.protobuf.CodedInputStream input)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(InputStream input)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(ByteBuffer data)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type SubscriptionQueryRequest

Modifier and Type	Method	Description
com.google.protobuf.Parser<SubscriptionQueryRequest>	SubscriptionQueryRequest.getParserForType()
static io.grpc.MethodDescriptor<SubscriptionQueryRequest,SubscriptionQueryResponse>	QueryServiceGrpc.getSubscriptionMethod()
static com.google.protobuf.Parser<SubscriptionQueryRequest>	SubscriptionQueryRequest.parser()
default io.grpc.stub.StreamObserver<SubscriptionQueryRequest>	QueryServiceGrpc.AsyncService.subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)	Opens a Subscription Query
io.grpc.stub.BlockingClientCall<SubscriptionQueryRequest,SubscriptionQueryResponse>	QueryServiceGrpc.QueryServiceBlockingV2Stub.subscription()	Opens a Subscription Query
io.grpc.stub.StreamObserver<SubscriptionQueryRequest>	QueryServiceGrpc.QueryServiceStub.subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver)	Opens a Subscription Query

Methods in io.axoniq.axonserver.grpc.query with parameters of type SubscriptionQueryRequest

Modifier and Type	Method	Description
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.mergeFrom(SubscriptionQueryRequest other)
QueryProviderInbound.Builder	QueryProviderInbound.Builder.mergeSubscriptionQueryRequest(SubscriptionQueryRequest value)	Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
static SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.newBuilder(SubscriptionQueryRequest prototype)
QueryProviderInbound.Builder	QueryProviderInbound.Builder.setSubscriptionQueryRequest(SubscriptionQueryRequest value)	Represents an incoming Subscription Query, for which this component is expected to provide a response and updates