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

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • hasRegister

        public boolean hasRegister()
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;
        Specified by:
        hasRegister in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the register field is set.

      • getRegister

        public ClientIdentification getRegister()
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;
        Specified by:
        getRegister in interface PlatformInboundInstructionOrBuilder
        Returns:
        The register.

      • setRegister

        public PlatformInboundInstruction.Builder setRegister​(ClientIdentification value)
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;

      • setRegister

        public PlatformInboundInstruction.Builder setRegister​(ClientIdentification.Builder builderForValue)
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;

      • mergeRegister

        public PlatformInboundInstruction.Builder mergeRegister​(ClientIdentification value)
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;

      • clearRegister

        public PlatformInboundInstruction.Builder clearRegister()
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;

      • getRegisterBuilder

        public ClientIdentification.Builder getRegisterBuilder()
         Information about the client being connected.
 This information is used by AxonServer to monitor the topology of connected applications.
        .io.axoniq.axonserver.grpc.control.ClientIdentification register = 1;

      • hasEventProcessorInfo

        public boolean hasEventProcessorInfo()
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;
        Specified by:
        hasEventProcessorInfo in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the eventProcessorInfo field is set.

      • getEventProcessorInfo

        public EventProcessorInfo getEventProcessorInfo()
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;
        Specified by:
        getEventProcessorInfo in interface PlatformInboundInstructionOrBuilder
        Returns:
        The eventProcessorInfo.

      • setEventProcessorInfo

        public PlatformInboundInstruction.Builder setEventProcessorInfo​(EventProcessorInfo value)
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;

      • setEventProcessorInfo

        public PlatformInboundInstruction.Builder setEventProcessorInfo​(EventProcessorInfo.Builder builderForValue)
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;

      • mergeEventProcessorInfo

        public PlatformInboundInstruction.Builder mergeEventProcessorInfo​(EventProcessorInfo value)
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;

      • clearEventProcessorInfo

        public PlatformInboundInstruction.Builder clearEventProcessorInfo()
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;

      • getEventProcessorInfoBuilder

        public EventProcessorInfo.Builder getEventProcessorInfoBuilder()
         Information about Processors defined in the application.
 This information is used by Axon Server to monitor the progress of Event Processors across instances.
        .io.axoniq.axonserver.grpc.control.EventProcessorInfo event_processor_info = 2;

      • hasHeartbeat

        public boolean hasHeartbeat()
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;
        Specified by:
        hasHeartbeat in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the heartbeat field is set.

      • getHeartbeat

        public Heartbeat getHeartbeat()
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;
        Specified by:
        getHeartbeat in interface PlatformInboundInstructionOrBuilder
        Returns:
        The heartbeat.

      • setHeartbeat

        public PlatformInboundInstruction.Builder setHeartbeat​(Heartbeat value)
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;

      • setHeartbeat

        public PlatformInboundInstruction.Builder setHeartbeat​(Heartbeat.Builder builderForValue)
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;

      • mergeHeartbeat

        public PlatformInboundInstruction.Builder mergeHeartbeat​(Heartbeat value)
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;

      • clearHeartbeat

        public PlatformInboundInstruction.Builder clearHeartbeat()
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;

      • getHeartbeatBuilder

        public Heartbeat.Builder getHeartbeatBuilder()
         This heartbeat is used by AxonServer in order to check if the connection is still alive
        .io.axoniq.axonserver.grpc.control.Heartbeat heartbeat = 3;

      • hasAck

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

      • clearAck

        public PlatformInboundInstruction.Builder clearAck()
         Acknowledgement of previously sent instruction via outbound stream
        .io.axoniq.axonserver.grpc.InstructionAck ack = 4;

      • getAckBuilder

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

      • hasResult

        public boolean hasResult()
         The result of the execution of an instruction
        .io.axoniq.axonserver.grpc.InstructionResult result = 6;
        Specified by:
        hasResult in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the result field is set.

      • clearResult

        public PlatformInboundInstruction.Builder clearResult()
         The result of the execution of an instruction
        .io.axoniq.axonserver.grpc.InstructionResult result = 6;

      • getResultBuilder

        public InstructionResult.Builder getResultBuilder()
         The result of the execution of an instruction
        .io.axoniq.axonserver.grpc.InstructionResult result = 6;

      • hasSubscribeTopologyChanges

        public boolean hasSubscribeTopologyChanges()
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;
        Specified by:
        hasSubscribeTopologyChanges in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the subscribeTopologyChanges field is set.

      • getSubscribeTopologyChanges

        public SubscribeTopologyChanges getSubscribeTopologyChanges()
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;
        Specified by:
        getSubscribeTopologyChanges in interface PlatformInboundInstructionOrBuilder
        Returns:
        The subscribeTopologyChanges.

      • setSubscribeTopologyChanges

        public PlatformInboundInstruction.Builder setSubscribeTopologyChanges​(SubscribeTopologyChanges value)
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;

      • setSubscribeTopologyChanges

        public PlatformInboundInstruction.Builder setSubscribeTopologyChanges​(SubscribeTopologyChanges.Builder builderForValue)
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;

      • mergeSubscribeTopologyChanges

        public PlatformInboundInstruction.Builder mergeSubscribeTopologyChanges​(SubscribeTopologyChanges value)
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;

      • clearSubscribeTopologyChanges

        public PlatformInboundInstruction.Builder clearSubscribeTopologyChanges()
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;

      • getSubscribeTopologyChangesBuilder

        public SubscribeTopologyChanges.Builder getSubscribeTopologyChangesBuilder()
         Subscribe to topology changes in the AxonServer cluster.
 This allows the client to receive updates about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.SubscribeTopologyChanges subscribe_topology_changes = 7;

      • hasUnsubscribeTopologyChanges

        public boolean hasUnsubscribeTopologyChanges()
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;
        Specified by:
        hasUnsubscribeTopologyChanges in interface PlatformInboundInstructionOrBuilder
        Returns:
        Whether the unsubscribeTopologyChanges field is set.

      • setUnsubscribeTopologyChanges

        public PlatformInboundInstruction.Builder setUnsubscribeTopologyChanges​(UnsubscribeTopologyChanges value)
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;

      • mergeUnsubscribeTopologyChanges

        public PlatformInboundInstruction.Builder mergeUnsubscribeTopologyChanges​(UnsubscribeTopologyChanges value)
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;

      • clearUnsubscribeTopologyChanges

        public PlatformInboundInstruction.Builder clearUnsubscribeTopologyChanges()
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;

      • getUnsubscribeTopologyChangesBuilder

        public UnsubscribeTopologyChanges.Builder getUnsubscribeTopologyChangesBuilder()
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;

      • getInstructionId

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

      • getInstructionIdBytes

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

      • setInstructionId

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

      • clearInstructionId

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

      • setInstructionIdBytes

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