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

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • hasNodeNotification

        public boolean hasNodeNotification()
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;
        Specified by:
        hasNodeNotification in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the nodeNotification field is set.

      • getNodeNotification

        public NodeInfo getNodeNotification()
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;
        Specified by:
        getNodeNotification in interface PlatformOutboundInstructionOrBuilder
        Returns:
        The nodeNotification.

      • setNodeNotification

        public PlatformOutboundInstruction.Builder setNodeNotification​(NodeInfo value)
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;

      • setNodeNotification

        public PlatformOutboundInstruction.Builder setNodeNotification​(NodeInfo.Builder builderForValue)
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;

      • mergeNodeNotification

        public PlatformOutboundInstruction.Builder mergeNodeNotification​(NodeInfo value)
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;

      • clearNodeNotification

        public PlatformOutboundInstruction.Builder clearNodeNotification()
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;

      • getNodeNotificationBuilder

        public NodeInfo.Builder getNodeNotificationBuilder()
         Information provided by AxonServer which provides information about the AxonServer node the application is connected with
        .io.axoniq.axonserver.grpc.control.NodeInfo node_notification = 1;

      • hasRequestReconnect

        public boolean hasRequestReconnect()
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;
        Specified by:
        hasRequestReconnect in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the requestReconnect field is set.

      • getRequestReconnect

        public RequestReconnect getRequestReconnect()
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;
        Specified by:
        getRequestReconnect in interface PlatformOutboundInstructionOrBuilder
        Returns:
        The requestReconnect.

      • setRequestReconnect

        public PlatformOutboundInstruction.Builder setRequestReconnect​(RequestReconnect value)
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;

      • setRequestReconnect

        public PlatformOutboundInstruction.Builder setRequestReconnect​(RequestReconnect.Builder builderForValue)
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;

      • mergeRequestReconnect

        public PlatformOutboundInstruction.Builder mergeRequestReconnect​(RequestReconnect value)
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;

      • clearRequestReconnect

        public PlatformOutboundInstruction.Builder clearRequestReconnect()
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;

      • getRequestReconnectBuilder

        public RequestReconnect.Builder getRequestReconnectBuilder()
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;

      • getRequestReconnectOrBuilder

        public RequestReconnectOrBuilder getRequestReconnectOrBuilder()
         A request from AxonServer to the Application to migrate its connection to another node.
 Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC
 to request a new destination.
        .io.axoniq.axonserver.grpc.control.RequestReconnect request_reconnect = 3;
        Specified by:
        getRequestReconnectOrBuilder in interface PlatformOutboundInstructionOrBuilder

      • hasPauseEventProcessor

        public boolean hasPauseEventProcessor()
         Instruction from AxonServer to Pause a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference pause_event_processor = 4;
        Specified by:
        hasPauseEventProcessor in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the pauseEventProcessor field is set.

      • clearPauseEventProcessor

        public PlatformOutboundInstruction.Builder clearPauseEventProcessor()
         Instruction from AxonServer to Pause a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference pause_event_processor = 4;

      • getPauseEventProcessorBuilder

        public EventProcessorReference.Builder getPauseEventProcessorBuilder()
         Instruction from AxonServer to Pause a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference pause_event_processor = 4;

      • hasStartEventProcessor

        public boolean hasStartEventProcessor()
         Instruction from AxonServer to Start a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference start_event_processor = 5;
        Specified by:
        hasStartEventProcessor in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the startEventProcessor field is set.

      • clearStartEventProcessor

        public PlatformOutboundInstruction.Builder clearStartEventProcessor()
         Instruction from AxonServer to Start a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference start_event_processor = 5;

      • getStartEventProcessorBuilder

        public EventProcessorReference.Builder getStartEventProcessorBuilder()
         Instruction from AxonServer to Start a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference start_event_processor = 5;

      • hasReleaseSegment

        public boolean hasReleaseSegment()
         Instruction from AxonServer to Release a specific segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference release_segment = 6;
        Specified by:
        hasReleaseSegment in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the releaseSegment field is set.

      • clearReleaseSegment

        public PlatformOutboundInstruction.Builder clearReleaseSegment()
         Instruction from AxonServer to Release a specific segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference release_segment = 6;

      • getReleaseSegmentBuilder

        public EventProcessorSegmentReference.Builder getReleaseSegmentBuilder()
         Instruction from AxonServer to Release a specific segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference release_segment = 6;

      • hasRequestEventProcessorInfo

        public boolean hasRequestEventProcessorInfo()
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;
        Specified by:
        hasRequestEventProcessorInfo in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the requestEventProcessorInfo field is set.

      • setRequestEventProcessorInfo

        public PlatformOutboundInstruction.Builder setRequestEventProcessorInfo​(EventProcessorReference value)
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;

      • setRequestEventProcessorInfo

        public PlatformOutboundInstruction.Builder setRequestEventProcessorInfo​(EventProcessorReference.Builder builderForValue)
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;

      • mergeRequestEventProcessorInfo

        public PlatformOutboundInstruction.Builder mergeRequestEventProcessorInfo​(EventProcessorReference value)
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;

      • clearRequestEventProcessorInfo

        public PlatformOutboundInstruction.Builder clearRequestEventProcessorInfo()
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;

      • getRequestEventProcessorInfoBuilder

        public EventProcessorReference.Builder getRequestEventProcessorInfoBuilder()
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;

      • hasSplitEventProcessorSegment

        public boolean hasSplitEventProcessorSegment()
         Instruction to split a Segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference split_event_processor_segment = 8;
        Specified by:
        hasSplitEventProcessorSegment in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the splitEventProcessorSegment field is set.

      • clearSplitEventProcessorSegment

        public PlatformOutboundInstruction.Builder clearSplitEventProcessorSegment()
         Instruction to split a Segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference split_event_processor_segment = 8;

      • getSplitEventProcessorSegmentBuilder

        public EventProcessorSegmentReference.Builder getSplitEventProcessorSegmentBuilder()
         Instruction to split a Segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference split_event_processor_segment = 8;

      • hasMergeEventProcessorSegment

        public boolean hasMergeEventProcessorSegment()
         Instruction to merge two Segments in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference merge_event_processor_segment = 9;
        Specified by:
        hasMergeEventProcessorSegment in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the mergeEventProcessorSegment field is set.

      • clearMergeEventProcessorSegment

        public PlatformOutboundInstruction.Builder clearMergeEventProcessorSegment()
         Instruction to merge two Segments in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference merge_event_processor_segment = 9;

      • getMergeEventProcessorSegmentBuilder

        public EventProcessorSegmentReference.Builder getMergeEventProcessorSegmentBuilder()
         Instruction to merge two Segments in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference merge_event_processor_segment = 9;

      • hasHeartbeat

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

      • getHeartbeat

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

      • setHeartbeat

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

      • setHeartbeat

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

      • mergeHeartbeat

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

      • clearHeartbeat

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

      • getHeartbeatBuilder

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

      • hasAck

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

      • clearAck

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

      • getAckBuilder

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

      • hasTopologyChange

        public boolean hasTopologyChange()
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;
        Specified by:
        hasTopologyChange in interface PlatformOutboundInstructionOrBuilder
        Returns:
        Whether the topologyChange field is set.

      • getTopologyChange

        public TopologyChange getTopologyChange()
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;
        Specified by:
        getTopologyChange in interface PlatformOutboundInstructionOrBuilder
        Returns:
        The topologyChange.

      • setTopologyChange

        public PlatformOutboundInstruction.Builder setTopologyChange​(TopologyChange value)
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;

      • setTopologyChange

        public PlatformOutboundInstruction.Builder setTopologyChange​(TopologyChange.Builder builderForValue)
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;

      • mergeTopologyChange

        public PlatformOutboundInstruction.Builder mergeTopologyChange​(TopologyChange value)
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;

      • clearTopologyChange

        public PlatformOutboundInstruction.Builder clearTopologyChange()
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;

      • getTopologyChangeBuilder

        public TopologyChange.Builder getTopologyChangeBuilder()
         Notification of a change in the topology of the AxonServer cluster.
 This is used to inform clients about changes in the cluster, such as handler additions or removals.
        .io.axoniq.axonserver.grpc.control.TopologyChange topology_change = 13;

      • getInstructionId

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

      • setInstructionId

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

      • clearInstructionId

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

      • setInstructionIdBytes

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