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

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • hasSubscribe

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

      • setSubscribe

        public CommandProviderOutbound.Builder setSubscribe​(CommandSubscription value)
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;

      • mergeSubscribe

        public CommandProviderOutbound.Builder mergeSubscribe​(CommandSubscription value)
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;

      • clearSubscribe

        public CommandProviderOutbound.Builder clearSubscribe()
         Instruction to subscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription subscribe = 1;

      • getSubscribeBuilder

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

      • hasUnsubscribe

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

      • setUnsubscribe

        public CommandProviderOutbound.Builder setUnsubscribe​(CommandSubscription value)
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;

      • mergeUnsubscribe

        public CommandProviderOutbound.Builder mergeUnsubscribe​(CommandSubscription value)
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;

      • clearUnsubscribe

        public CommandProviderOutbound.Builder clearUnsubscribe()
         Instruction to unsubscribe this component as handler of a specific type of command
        .io.axoniq.axonserver.grpc.command.CommandSubscription unsubscribe = 2;

      • getUnsubscribeBuilder

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

      • hasFlowControl

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

      • getFlowControl

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

      • setFlowControl

        public CommandProviderOutbound.Builder setFlowControl​(FlowControl value)
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • setFlowControl

        public CommandProviderOutbound.Builder setFlowControl​(FlowControl.Builder builderForValue)
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • mergeFlowControl

        public CommandProviderOutbound.Builder mergeFlowControl​(FlowControl value)
         Instruction to increase the number of instructions AxonServer may send to this component
        .io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

      • clearFlowControl

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

      • getFlowControlBuilder

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

      • hasCommandResponse

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

      • clearCommandResponse

        public CommandProviderOutbound.Builder clearCommandResponse()
         Sends a result of Command processing
        .io.axoniq.axonserver.grpc.command.CommandResponse command_response = 4;

      • getCommandResponseBuilder

        public CommandResponse.Builder getCommandResponseBuilder()
         Sends a result of Command processing
        .io.axoniq.axonserver.grpc.command.CommandResponse command_response = 4;

      • hasAck

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

      • clearAck

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

      • getAckBuilder

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

      • getInstructionId

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

      • setInstructionId

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

      • clearInstructionId

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

      • setInstructionIdBytes

        public CommandProviderOutbound.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 = 6;
        Parameters:
        value - The bytes for instructionId to set.
        Returns:
        This builder for chaining.