io.axoniq.axonserver.grpc.query

Interface SubscriptionQueryRequestOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

SubscriptionQueryRequest, SubscriptionQueryRequest.Builder

public interface SubscriptionQueryRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
SubscriptionQuery	getFlowControl() Allows the Server to provide additional Updates to be sent.
SubscriptionQueryOrBuilder	getFlowControlOrBuilder() Allows the Server to provide additional Updates to be sent.
SubscriptionQuery	getGetInitialResult() Requests the initial result of a subscription query to be sent.
SubscriptionQueryOrBuilder	getGetInitialResultOrBuilder() Requests the initial result of a subscription query to be sent.
SubscriptionQueryRequest.RequestCase	getRequestCase()
SubscriptionQuery	getSubscribe() Start a Subscription Query with the given details.
SubscriptionQueryOrBuilder	getSubscribeOrBuilder() Start a Subscription Query with the given details.
SubscriptionQuery	getUnsubscribe() Ends a previously started Subscription Query with the given details
SubscriptionQueryOrBuilder	getUnsubscribeOrBuilder() Ends a previously started Subscription Query with the given details
boolean	hasFlowControl() Allows the Server to provide additional Updates to be sent.
boolean	hasGetInitialResult() Requests the initial result of a subscription query to be sent.
boolean	hasSubscribe() Start a Subscription Query with the given details.
boolean	hasUnsubscribe() Ends a previously started Subscription Query with the given details

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

hasSubscribe

boolean hasSubscribe()

 Start a Subscription Query with the given details. 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;

getSubscribe

SubscriptionQuery getSubscribe()

 Start a Subscription Query with the given details. 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;

getSubscribeOrBuilder

SubscriptionQueryOrBuilder getSubscribeOrBuilder()

 Start a Subscription Query with the given details. 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;

hasUnsubscribe

boolean hasUnsubscribe()

 Ends a previously started Subscription Query with the given details 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

getUnsubscribe

SubscriptionQuery getUnsubscribe()

 Ends a previously started Subscription Query with the given details 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

getUnsubscribeOrBuilder

SubscriptionQueryOrBuilder getUnsubscribeOrBuilder()

 Ends a previously started Subscription Query with the given details 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

hasGetInitialResult

boolean hasGetInitialResult()

 Requests the initial result of a subscription query to be sent. This should always be done after opening the
subscription query itself, to remove concurrency conflicts with Update messages.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;

getGetInitialResult

SubscriptionQuery getGetInitialResult()

 Requests the initial result of a subscription query to be sent. This should always be done after opening the
subscription query itself, to remove concurrency conflicts with Update messages.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;

getGetInitialResultOrBuilder

SubscriptionQueryOrBuilder getGetInitialResultOrBuilder()

 Requests the initial result of a subscription query to be sent. This should always be done after opening the
subscription query itself, to remove concurrency conflicts with Update messages.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3;

hasFlowControl

boolean hasFlowControl()

 Allows the Server to provide additional Updates to be sent. Only the `number_of_permits` field needs to be
set on this message.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;

getFlowControl

SubscriptionQuery getFlowControl()

 Allows the Server to provide additional Updates to be sent. Only the `number_of_permits` field needs to be
set on this message.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;

getFlowControlOrBuilder

SubscriptionQueryOrBuilder getFlowControlOrBuilder()

 Allows the Server to provide additional Updates to be sent. Only the `number_of_permits` field needs to be
set on this message.
 

.io.axoniq.axonserver.grpc.query.SubscriptionQuery flow_control = 4;

getRequestCase

SubscriptionQueryRequest.RequestCase getRequestCase()