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

Packages that use SubscriptionQueryResponse

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

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

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

Modifier and Type	Method and Description
SubscriptionQueryResponse	SubscriptionQueryResponse.Builder.build()
SubscriptionQueryResponse	SubscriptionQueryResponse.Builder.buildPartial()
static SubscriptionQueryResponse	SubscriptionQueryResponse.getDefaultInstance()
SubscriptionQueryResponse	SubscriptionQueryResponse.getDefaultInstanceForType()
SubscriptionQueryResponse	SubscriptionQueryResponse.Builder.getDefaultInstanceForType()
SubscriptionQueryResponse	QueryProviderOutboundOrBuilder.getSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
SubscriptionQueryResponse	QueryProviderOutbound.getSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
SubscriptionQueryResponse	QueryProviderOutbound.Builder.getSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseDelimitedFrom(InputStream input)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(byte[] data)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(ByteBuffer data)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(com.google.protobuf.ByteString data)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(com.google.protobuf.CodedInputStream input)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(InputStream input)
static SubscriptionQueryResponse	SubscriptionQueryResponse.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

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

Modifier and Type	Method and Description
com.google.protobuf.Parser<SubscriptionQueryResponse>	SubscriptionQueryResponse.getParserForType()
static io.grpc.MethodDescriptor<SubscriptionQueryRequest,SubscriptionQueryResponse>	QueryServiceGrpc.getSubscriptionMethod()
static com.google.protobuf.Parser<SubscriptionQueryResponse>	SubscriptionQueryResponse.parser()

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

Modifier and Type	Method and Description
SubscriptionQueryResponse.Builder	SubscriptionQueryResponse.Builder.mergeFrom(SubscriptionQueryResponse other)
QueryProviderOutbound.Builder	QueryProviderOutbound.Builder.mergeSubscriptionQueryResponse(SubscriptionQueryResponse value) Sends a response for a Subscription Query that has been received via the inbound stream
static SubscriptionQueryResponse.Builder	SubscriptionQueryResponse.newBuilder(SubscriptionQueryResponse prototype)
QueryProviderOutbound.Builder	QueryProviderOutbound.Builder.setSubscriptionQueryResponse(SubscriptionQueryResponse value) Sends a response for a Subscription Query that has been received via the inbound stream

Method parameters in io.axoniq.axonserver.grpc.query with type arguments of type SubscriptionQueryResponse

Modifier and Type	Method and Description
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

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

Methods in org.axonframework.axonserver.connector.query.subscription with parameters of type SubscriptionQueryResponse

Modifier and Type	Method and Description
void	AxonServerSubscriptionQueryResult.onNext(SubscriptionQueryResponse response)

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

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.