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

Class QueryProviderOutbound.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<QueryProviderOutbound.Builder>

      • clear

        public QueryProviderOutbound.Builder clear()
        Specified by:
        clear in interface com.google.protobuf.Message.Builder
        Specified by:
        clear in interface com.google.protobuf.MessageLite.Builder
        Overrides:
        clear in class com.google.protobuf.GeneratedMessage.Builder<QueryProviderOutbound.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<QueryProviderOutbound.Builder>

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

        public QueryProviderOutbound 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<QueryProviderOutbound.Builder>

      • mergeFrom

        public QueryProviderOutbound.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<QueryProviderOutbound.Builder>
        Throws:
        IOException

      • hasSubscribe

        public boolean hasSubscribe()
         Registers a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;
        Specified by:
        hasSubscribe in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the subscribe field is set.

      • clearSubscribe

        public QueryProviderOutbound.Builder clearSubscribe()
         Registers a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

      • getSubscribeBuilder

        public QuerySubscription.Builder getSubscribeBuilder()
         Registers a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

      • hasUnsubscribe

        public boolean hasUnsubscribe()
         Unregisters a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;
        Specified by:
        hasUnsubscribe in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the unsubscribe field is set.

      • clearUnsubscribe

        public QueryProviderOutbound.Builder clearUnsubscribe()
         Unregisters a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

      • getUnsubscribeBuilder

        public QuerySubscription.Builder getUnsubscribeBuilder()
         Unregisters a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

      • hasFlowControl

        public boolean hasFlowControl()
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
        Specified by:
        hasFlowControl in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the flowControl field is set.

      • getFlowControl

        public FlowControl getFlowControl()
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
        Specified by:
        getFlowControl in interface QueryProviderOutboundOrBuilder
        Returns:
        The flowControl.

      • setFlowControl

        public QueryProviderOutbound.Builder setFlowControl​(FlowControl value)
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • mergeFlowControl

        public QueryProviderOutbound.Builder mergeFlowControl​(FlowControl value)
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • clearFlowControl

        public QueryProviderOutbound.Builder clearFlowControl()
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • getFlowControlBuilder

        public FlowControl.Builder getFlowControlBuilder()
         Grant permits to AxonServer to send a number of messages to the client
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • hasQueryResponse

        public boolean hasQueryResponse()
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;
        Specified by:
        hasQueryResponse in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the queryResponse field is set.

      • setQueryResponse

        public QueryProviderOutbound.Builder setQueryResponse​(QueryResponse value)
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

      • mergeQueryResponse

        public QueryProviderOutbound.Builder mergeQueryResponse​(QueryResponse value)
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

      • clearQueryResponse

        public QueryProviderOutbound.Builder clearQueryResponse()
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

      • getQueryResponseBuilder

        public QueryResponse.Builder getQueryResponseBuilder()
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

      • hasQueryComplete

        public boolean hasQueryComplete()
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;
        Specified by:
        hasQueryComplete in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the queryComplete field is set.

      • setQueryComplete

        public QueryProviderOutbound.Builder setQueryComplete​(QueryComplete value)
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

      • mergeQueryComplete

        public QueryProviderOutbound.Builder mergeQueryComplete​(QueryComplete value)
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

      • clearQueryComplete

        public QueryProviderOutbound.Builder clearQueryComplete()
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

      • getQueryCompleteBuilder

        public QueryComplete.Builder getQueryCompleteBuilder()
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

      • hasSubscriptionQueryResponse

        public boolean hasSubscriptionQueryResponse()
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;
        Specified by:
        hasSubscriptionQueryResponse in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the subscriptionQueryResponse field is set.

      • setSubscriptionQueryResponse

        public QueryProviderOutbound.Builder setSubscriptionQueryResponse​(SubscriptionQueryResponse value)
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

      • setSubscriptionQueryResponse

        public QueryProviderOutbound.Builder setSubscriptionQueryResponse​(SubscriptionQueryResponse.Builder builderForValue)
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

      • mergeSubscriptionQueryResponse

        public QueryProviderOutbound.Builder mergeSubscriptionQueryResponse​(SubscriptionQueryResponse value)
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

      • clearSubscriptionQueryResponse

        public QueryProviderOutbound.Builder clearSubscriptionQueryResponse()
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

      • getSubscriptionQueryResponseBuilder

        public SubscriptionQueryResponse.Builder getSubscriptionQueryResponseBuilder()
         Sends a response for a Subscription Query that has been received via the inbound stream
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

      • hasAck

        public boolean hasAck()
         Acknowledgement of previously sent instruction via inbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 7;
        Specified by:
        hasAck in interface QueryProviderOutboundOrBuilder
        Returns:
        Whether the ack field is set.

      • clearAck

        public QueryProviderOutbound.Builder clearAck()
         Acknowledgement of previously sent instruction via inbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 7;

      • getAckBuilder

        public InstructionAck.Builder getAckBuilder()
         Acknowledgement of previously sent instruction via inbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 7;

      • getInstructionId

        public String getInstructionId()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 8;
        Specified by:
        getInstructionId in interface QueryProviderOutboundOrBuilder
        Returns:
        The instructionId.

      • getInstructionIdBytes

        public com.google.protobuf.ByteString getInstructionIdBytes()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 8;
        Specified by:
        getInstructionIdBytes in interface QueryProviderOutboundOrBuilder
        Returns:
        The bytes for instructionId.

      • setInstructionId

        public QueryProviderOutbound.Builder setInstructionId​(String value)
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 8;
        Parameters:
        value - The instructionId to set.
        Returns:
        This builder for chaining.

      • clearInstructionId

        public QueryProviderOutbound.Builder clearInstructionId()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 8;
        Returns:
        This builder for chaining.

      • setInstructionIdBytes

        public QueryProviderOutbound.Builder setInstructionIdBytes​(com.google.protobuf.ByteString value)
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 8;
        Parameters:
        value - The bytes for instructionId to set.
        Returns:
        This builder for chaining.