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

Packages that use SubscriptionQueryRequest

Package	Description
io.axoniq.axonserver.grpc.query
org.axonframework.axonserver.connector.query.subscription

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

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

Modifier and Type	Method and Description
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.build()
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.buildPartial()
static SubscriptionQueryRequest	SubscriptionQueryRequest.getDefaultInstance()
SubscriptionQueryRequest	SubscriptionQueryRequest.getDefaultInstanceForType()
SubscriptionQueryRequest	SubscriptionQueryRequest.Builder.getDefaultInstanceForType()
SubscriptionQueryRequest	QueryProviderInboundOrBuilder.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	QueryProviderInbound.Builder.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(ByteBuffer data)
static SubscriptionQueryRequest	SubscriptionQueryRequest.parseFrom(ByteBuffer 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)

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

Modifier and Type	Method and Description
com.google.protobuf.Parser<SubscriptionQueryRequest>	SubscriptionQueryRequest.getParserForType()
static io.grpc.MethodDescriptor<SubscriptionQueryRequest,SubscriptionQueryResponse>	QueryServiceGrpc.getSubscriptionMethod()
static com.google.protobuf.Parser<SubscriptionQueryRequest>	SubscriptionQueryRequest.parser()
io.grpc.stub.StreamObserver<SubscriptionQueryRequest>	QueryServiceGrpc.QueryServiceImplBase.subscription(io.grpc.stub.StreamObserver<SubscriptionQueryResponse> responseObserver) 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 and 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

Uses of SubscriptionQueryRequest in org.axonframework.axonserver.connector.query.subscription

Constructor parameters in org.axonframework.axonserver.connector.query.subscription with type arguments of type SubscriptionQueryRequest

Constructor and Description

AxonServerSubscriptionQueryResult(SubscriptionQuery subscriptionQuery, Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn, AxonServerConfiguration configuration, SubscriptionQueryBackpressure backPressure, int bufferSize, Runnable onDispose) Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.