Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.query

Class SubscriptionQueryRequest.Builder

    • Method Detail

      • getDescriptor

        public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<SubscriptionQueryRequest.Builder>

      • getDescriptorForType

        public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
        Specified by:
        getDescriptorForType in interface com.google.protobuf.Message.Builder
        Specified by:
        getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
        Overrides:
        getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<SubscriptionQueryRequest.Builder>

      • getDefaultInstanceForType

        public SubscriptionQueryRequest getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

      • build

        public SubscriptionQueryRequest build()
        Specified by:
        build in interface com.google.protobuf.Message.Builder
        Specified by:
        build in interface com.google.protobuf.MessageLite.Builder

      • buildPartial

        public SubscriptionQueryRequest buildPartial()
        Specified by:
        buildPartial in interface com.google.protobuf.Message.Builder
        Specified by:
        buildPartial in interface com.google.protobuf.MessageLite.Builder

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessage.Builder<SubscriptionQueryRequest.Builder>

      • mergeFrom

        public SubscriptionQueryRequest.Builder mergeFrom​(com.google.protobuf.CodedInputStream input,
                                                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws IOException
        Specified by:
        mergeFrom in interface com.google.protobuf.Message.Builder
        Specified by:
        mergeFrom in interface com.google.protobuf.MessageLite.Builder
        Overrides:
        mergeFrom in class com.google.protobuf.AbstractMessage.Builder<SubscriptionQueryRequest.Builder>
        Throws:
        IOException

      • hasSubscribe

        public boolean hasSubscribe()
         Start a Subscription Query with the given details.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
        Specified by:
        hasSubscribe in interface SubscriptionQueryRequestOrBuilder
        Returns:
        Whether the subscribe field is set.

      • clearSubscribe

        public SubscriptionQueryRequest.Builder clearSubscribe()
         Start a Subscription Query with the given details.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;

      • getSubscribeBuilder

        public SubscriptionQuery.Builder getSubscribeBuilder()
         Start a Subscription Query with the given details.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;

      • hasUnsubscribe

        public boolean hasUnsubscribe()
         Ends a previously started Subscription Query with the given details
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
        Specified by:
        hasUnsubscribe in interface SubscriptionQueryRequestOrBuilder
        Returns:
        Whether the unsubscribe field is set.

      • clearUnsubscribe

        public SubscriptionQueryRequest.Builder clearUnsubscribe()
         Ends a previously started Subscription Query with the given details
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

      • getUnsubscribeBuilder

        public SubscriptionQuery.Builder getUnsubscribeBuilder()
         Ends a previously started Subscription Query with the given details
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;

      • hasGetInitialResult

        @Deprecated
public boolean hasGetInitialResult()
        Deprecated.
        io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest.get_initial_result is deprecated. See query.proto;l=251
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];
        Specified by:
        hasGetInitialResult in interface SubscriptionQueryRequestOrBuilder
        Returns:
        Whether the getInitialResult field is set.

      • getGetInitialResult

        @Deprecated
public SubscriptionQuery getGetInitialResult()
        Deprecated.
        io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest.get_initial_result is deprecated. See query.proto;l=251
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];
        Specified by:
        getGetInitialResult in interface SubscriptionQueryRequestOrBuilder
        Returns:
        The getInitialResult.

      • setGetInitialResult

        @Deprecated
public SubscriptionQueryRequest.Builder setGetInitialResult​(SubscriptionQuery value)
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];

      • setGetInitialResult

        @Deprecated
public SubscriptionQueryRequest.Builder setGetInitialResult​(SubscriptionQuery.Builder builderForValue)
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];

      • mergeGetInitialResult

        @Deprecated
public SubscriptionQueryRequest.Builder mergeGetInitialResult​(SubscriptionQuery value)
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];

      • clearGetInitialResult

        @Deprecated
public SubscriptionQueryRequest.Builder clearGetInitialResult()
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];

      • getGetInitialResultBuilder

        @Deprecated
public SubscriptionQuery.Builder getGetInitialResultBuilder()
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];

      • getGetInitialResultOrBuilder

        @Deprecated
public SubscriptionQueryOrBuilder getGetInitialResultOrBuilder()
        Deprecated.
         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.

 Note that this request is deprecated. It is recommended to retrieve the initial request using a regular query.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery get_initial_result = 3 [deprecated = true];
        Specified by:
        getGetInitialResultOrBuilder in interface SubscriptionQueryRequestOrBuilder

      • hasFlowControl

        public 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;
        Specified by:
        hasFlowControl in interface SubscriptionQueryRequestOrBuilder
        Returns:
        Whether the flowControl field is set.

      • getFlowControl

        public 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;
        Specified by:
        getFlowControl in interface SubscriptionQueryRequestOrBuilder
        Returns:
        The flowControl.

      • setFlowControl

        public SubscriptionQueryRequest.Builder setFlowControl​(SubscriptionQuery value)
         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;

      • setFlowControl

        public SubscriptionQueryRequest.Builder setFlowControl​(SubscriptionQuery.Builder builderForValue)
         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;

      • mergeFlowControl

        public SubscriptionQueryRequest.Builder mergeFlowControl​(SubscriptionQuery value)
         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;

      • clearFlowControl

        public SubscriptionQueryRequest.Builder clearFlowControl()
         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;

      • getFlowControlBuilder

        public SubscriptionQuery.Builder getFlowControlBuilder()
         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;