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

Interface SubscriptionQueryRequestOrBuilder

  • All Superinterfaces:
    com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
    All Known Implementing Classes:
    SubscriptionQueryRequest, SubscriptionQueryRequest.Builder
    @Generated
public interface SubscriptionQueryRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder

    • Method Detail

      • hasSubscribe

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

      • getSubscribe

        SubscriptionQuery getSubscribe()
         Start a Subscription Query with the given details.
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery subscribe = 1;
        Returns:
        The subscribe.

      • 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;
        Returns:
        Whether the unsubscribe field is set.

      • getUnsubscribe

        SubscriptionQuery getUnsubscribe()
         Ends a previously started Subscription Query with the given details
        .io.axoniq.axonserver.grpc.query.SubscriptionQuery unsubscribe = 2;
        Returns:
        The unsubscribe.

      • getUnsubscribeOrBuilder

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

      • hasGetInitialResult

        @Deprecated
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];
        Returns:
        Whether the getInitialResult field is set.

      • getGetInitialResult

        @Deprecated
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];
        Returns:
        The getInitialResult.

      • getGetInitialResultOrBuilder

        @Deprecated
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];

      • 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;
        Returns:
        Whether the flowControl field is set.

      • 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;
        Returns:
        The flowControl.

      • 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;