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

Interface QueryProviderInboundOrBuilder

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

    • Method Detail

      • hasAck

        boolean hasAck()
         Acknowledgement of previously sent instruction via outbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 1;
        Returns:
        Whether the ack field is set.

      • getAck

        InstructionAck getAck()
         Acknowledgement of previously sent instruction via outbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 1;
        Returns:
        The ack.

      • getAckOrBuilder

        InstructionAckOrBuilder getAckOrBuilder()
         Acknowledgement of previously sent instruction via outbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 1;

      • hasQuery

        boolean hasQuery()
         Represents an incoming Query, for which this component is expected to provide a response
        .io.axoniq.axonserver.grpc.query.QueryRequest query = 2;
        Returns:
        Whether the query field is set.

      • getQuery

        QueryRequest getQuery()
         Represents an incoming Query, for which this component is expected to provide a response
        .io.axoniq.axonserver.grpc.query.QueryRequest query = 2;
        Returns:
        The query.

      • getQueryOrBuilder

        QueryRequestOrBuilder getQueryOrBuilder()
         Represents an incoming Query, for which this component is expected to provide a response
        .io.axoniq.axonserver.grpc.query.QueryRequest query = 2;

      • hasSubscriptionQueryRequest

        boolean hasSubscriptionQueryRequest()
         Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest subscription_query_request = 3;
        Returns:
        Whether the subscriptionQueryRequest field is set.

      • getSubscriptionQueryRequest

        SubscriptionQueryRequest getSubscriptionQueryRequest()
         Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest subscription_query_request = 3;
        Returns:
        The subscriptionQueryRequest.

      • getSubscriptionQueryRequestOrBuilder

        SubscriptionQueryRequestOrBuilder getSubscriptionQueryRequestOrBuilder()
         Represents an incoming Subscription Query, for which this component is expected to provide a response and updates
        .io.axoniq.axonserver.grpc.query.SubscriptionQueryRequest subscription_query_request = 3;

      • hasQueryCancel

        boolean hasQueryCancel()
         Indicator that receiver is no more interested in updates of this query
        .io.axoniq.axonserver.grpc.query.QueryReference query_cancel = 5;
        Returns:
        Whether the queryCancel field is set.

      • getQueryCancel

        QueryReference getQueryCancel()
         Indicator that receiver is no more interested in updates of this query
        .io.axoniq.axonserver.grpc.query.QueryReference query_cancel = 5;
        Returns:
        The queryCancel.

      • getQueryCancelOrBuilder

        QueryReferenceOrBuilder getQueryCancelOrBuilder()
         Indicator that receiver is no more interested in updates of this query
        .io.axoniq.axonserver.grpc.query.QueryReference query_cancel = 5;

      • hasQueryFlowControl

        boolean hasQueryFlowControl()
         Indicator that receiver should send more updates of this query
        .io.axoniq.axonserver.grpc.query.QueryFlowControl query_flow_control = 6;
        Returns:
        Whether the queryFlowControl field is set.

      • getQueryFlowControl

        QueryFlowControl getQueryFlowControl()
         Indicator that receiver should send more updates of this query
        .io.axoniq.axonserver.grpc.query.QueryFlowControl query_flow_control = 6;
        Returns:
        The queryFlowControl.

      • getQueryFlowControlOrBuilder

        QueryFlowControlOrBuilder getQueryFlowControlOrBuilder()
         Indicator that receiver should send more updates of this query
        .io.axoniq.axonserver.grpc.query.QueryFlowControl query_flow_control = 6;

      • getInstructionId

        String getInstructionId()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via outbound stream
        string instruction_id = 4;
        Returns:
        The instructionId.

      • getInstructionIdBytes

        com.google.protobuf.ByteString getInstructionIdBytes()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via outbound stream
        string instruction_id = 4;
        Returns:
        The bytes for instructionId.