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

Interface CommandProviderOutboundOrBuilder

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

    • Method Detail

      • hasSubscribe

        boolean hasSubscribe()
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;
        Returns:
        Whether the subscribe field is set.

      • getSubscribe

        CommandSubscription getSubscribe()
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;
        Returns:
        The subscribe.

      • getSubscribeOrBuilder

        CommandSubscriptionOrBuilder getSubscribeOrBuilder()
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;

      • hasUnsubscribe

        boolean hasUnsubscribe()
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;
        Returns:
        Whether the unsubscribe field is set.

      • getUnsubscribe

        CommandSubscription getUnsubscribe()
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;
        Returns:
        The unsubscribe.

      • getUnsubscribeOrBuilder

        CommandSubscriptionOrBuilder getUnsubscribeOrBuilder()
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;

      • hasFlowControl

        boolean hasFlowControl()
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
        Returns:
        Whether the flowControl field is set.

      • getFlowControl

        FlowControl getFlowControl()
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
        Returns:
        The flowControl.

      • getFlowControlOrBuilder

        FlowControlOrBuilder getFlowControlOrBuilder()
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • hasCommandResponse

        boolean hasCommandResponse()
         Sends a result of Command processing
        .io.axoniq.axonserver.grpc.command.CommandResponse command_response = 4;
        Returns:
        Whether the commandResponse field is set.

      • getCommandResponse

        CommandResponse getCommandResponse()
         Sends a result of Command processing
        .io.axoniq.axonserver.grpc.command.CommandResponse command_response = 4;
        Returns:
        The commandResponse.

      • getCommandResponseOrBuilder

        CommandResponseOrBuilder getCommandResponseOrBuilder()
         Sends a result of Command processing
        .io.axoniq.axonserver.grpc.command.CommandResponse command_response = 4;

      • hasAck

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

      • getAck

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

      • getAckOrBuilder

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

      • getInstructionId

        String getInstructionId()
         Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
        string instruction_id = 6;
        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 = 6;
        Returns:
        The bytes for instructionId.