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

Interface QueryProviderOutboundOrBuilder

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

    • Method Detail

      • hasSubscribe

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

      • getSubscribe

        QuerySubscription getSubscribe()
         Registers a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;
        Returns:
        The subscribe.

      • getSubscribeOrBuilder

        QuerySubscriptionOrBuilder getSubscribeOrBuilder()
         Registers a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

      • hasUnsubscribe

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

      • getUnsubscribe

        QuerySubscription getUnsubscribe()
         Unregisters a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;
        Returns:
        The unsubscribe.

      • getUnsubscribeOrBuilder

        QuerySubscriptionOrBuilder getUnsubscribeOrBuilder()
         Unregisters a Query Handler with AxonServer
        .io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

      • hasFlowControl

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

      • getFlowControl

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

      • getFlowControlOrBuilder

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

      • hasQueryResponse

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

      • getQueryResponse

        QueryResponse getQueryResponse()
         Sends a Response to a Query received via the inbound stream
        .io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;
        Returns:
        The queryResponse.

      • getQueryResponseOrBuilder

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

      • hasQueryComplete

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

      • getQueryComplete

        QueryComplete getQueryComplete()
         Indicator that all responses for Query have been sent
        .io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;
        Returns:
        The queryComplete.

      • getQueryCompleteOrBuilder

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

      • hasSubscriptionQueryResponse

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

      • getSubscriptionQueryResponse

        SubscriptionQueryResponse getSubscriptionQueryResponse()
         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;
        Returns:
        The subscriptionQueryResponse.

      • getSubscriptionQueryResponseOrBuilder

        SubscriptionQueryResponseOrBuilder getSubscriptionQueryResponseOrBuilder()
         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

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

      • getAck

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

      • getAckOrBuilder

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

      • getInstructionId

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

      • getInstructionIdBytes

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