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

Packages that use SubscriptionQuery

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

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

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

Modifier and Type	Method and Description
SubscriptionQuery	SubscriptionQuery.Builder.build()
SubscriptionQuery	SubscriptionQuery.Builder.buildPartial()
static SubscriptionQuery	SubscriptionQuery.getDefaultInstance()
SubscriptionQuery	SubscriptionQuery.getDefaultInstanceForType()
SubscriptionQuery	SubscriptionQuery.Builder.getDefaultInstanceForType()
SubscriptionQuery	SubscriptionQueryRequest.getFlowControl() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;
SubscriptionQuery	SubscriptionQueryRequest.Builder.getFlowControl() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;
SubscriptionQuery	SubscriptionQueryRequestOrBuilder.getFlowControl() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;
SubscriptionQuery	SubscriptionQueryRequest.getGetInitialResult() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;
SubscriptionQuery	SubscriptionQueryRequest.Builder.getGetInitialResult() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;
SubscriptionQuery	SubscriptionQueryRequestOrBuilder.getGetInitialResult() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;
SubscriptionQuery	SubscriptionQueryRequest.getSubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
SubscriptionQuery	SubscriptionQueryRequest.Builder.getSubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
SubscriptionQuery	SubscriptionQueryRequestOrBuilder.getSubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
SubscriptionQuery	SubscriptionQueryRequest.getUnsubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
SubscriptionQuery	SubscriptionQueryRequest.Builder.getUnsubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
SubscriptionQuery	SubscriptionQueryRequestOrBuilder.getUnsubscribe() optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
static SubscriptionQuery	SubscriptionQuery.parseDelimitedFrom(InputStream input)
static SubscriptionQuery	SubscriptionQuery.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQuery	SubscriptionQuery.parseFrom(byte[] data)
static SubscriptionQuery	SubscriptionQuery.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQuery	SubscriptionQuery.parseFrom(com.google.protobuf.ByteString data)
static SubscriptionQuery	SubscriptionQuery.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQuery	SubscriptionQuery.parseFrom(com.google.protobuf.CodedInputStream input)
static SubscriptionQuery	SubscriptionQuery.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static SubscriptionQuery	SubscriptionQuery.parseFrom(InputStream input)
static SubscriptionQuery	SubscriptionQuery.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

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

Modifier and Type	Method and Description
com.google.protobuf.Parser<SubscriptionQuery>	SubscriptionQuery.getParserForType()
static com.google.protobuf.Parser<SubscriptionQuery>	SubscriptionQuery.parser()

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

Modifier and Type	Method and Description
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.mergeFlowControl(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;
SubscriptionQuery.Builder	SubscriptionQuery.Builder.mergeFrom(SubscriptionQuery other)
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.mergeGetInitialResult(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.mergeSubscribe(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.mergeUnsubscribe(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
static SubscriptionQuery.Builder	SubscriptionQuery.newBuilder(SubscriptionQuery prototype)
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.setFlowControl(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.setGetInitialResult(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.setSubscribe(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
SubscriptionQueryRequest.Builder	SubscriptionQueryRequest.Builder.setUnsubscribe(SubscriptionQuery value) optional .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

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

Methods in org.axonframework.axonserver.connector.query.subscription that return SubscriptionQuery

Modifier and Type	Method and Description
SubscriptionQuery	SubscriptionMessageSerializer.serialize(SubscriptionQueryMessage message)

Constructors in org.axonframework.axonserver.connector.query.subscription with parameters of type SubscriptionQuery

Constructor and Description
AxonServerSubscriptionQueryResult(SubscriptionQuery query, Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn, AxonServerConfiguration configuration, SubscriptionQueryBackpressure backPressure, int bufferSize, Runnable onDispose)
GrpcBackedSubscriptionQueryMessage(SubscriptionQuery subscriptionQuery, Serializer messageSerializer, Serializer genericSerializer)