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

Interface PlatformOutboundInstructionOrBuilder

    • Method Detail

      • hasNodeNotification

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

      • getNodeNotification

        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;
        Returns:
        The nodeNotification.

      • getNodeNotificationOrBuilder

        NodeInfoOrBuilder getNodeNotificationOrBuilder()
         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

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

      • getRequestReconnect

        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;
        Returns:
        The requestReconnect.

      • getRequestReconnectOrBuilder

        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;

      • hasPauseEventProcessor

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

      • getPauseEventProcessor

        EventProcessorReference getPauseEventProcessor()
         Instruction from AxonServer to Pause a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference pause_event_processor = 4;
        Returns:
        The pauseEventProcessor.

      • getPauseEventProcessorOrBuilder

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

      • hasStartEventProcessor

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

      • getStartEventProcessor

        EventProcessorReference getStartEventProcessor()
         Instruction from AxonServer to Start a Streaming Event Processor.
        .io.axoniq.axonserver.grpc.control.EventProcessorReference start_event_processor = 5;
        Returns:
        The startEventProcessor.

      • getStartEventProcessorOrBuilder

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

      • hasReleaseSegment

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

      • getReleaseSegment

        EventProcessorSegmentReference getReleaseSegment()
         Instruction from AxonServer to Release a specific segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference release_segment = 6;
        Returns:
        The releaseSegment.

      • getReleaseSegmentOrBuilder

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

      • hasRequestEventProcessorInfo

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

      • getRequestEventProcessorInfo

        EventProcessorReference getRequestEventProcessorInfo()
         A request from AxonServer for status information of a specific Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorReference request_event_processor_info = 7;
        Returns:
        The requestEventProcessorInfo.

      • getRequestEventProcessorInfoOrBuilder

        EventProcessorReferenceOrBuilder getRequestEventProcessorInfoOrBuilder()
         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

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

      • getSplitEventProcessorSegment

        EventProcessorSegmentReference getSplitEventProcessorSegment()
         Instruction to split a Segment in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference split_event_processor_segment = 8;
        Returns:
        The splitEventProcessorSegment.

      • getSplitEventProcessorSegmentOrBuilder

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

      • hasMergeEventProcessorSegment

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

      • getMergeEventProcessorSegment

        EventProcessorSegmentReference getMergeEventProcessorSegment()
         Instruction to merge two Segments in a Streaming Event Processor
        .io.axoniq.axonserver.grpc.control.EventProcessorSegmentReference merge_event_processor_segment = 9;
        Returns:
        The mergeEventProcessorSegment.

      • getMergeEventProcessorSegmentOrBuilder

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

      • hasHeartbeat

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

      • getHeartbeat

        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;
        Returns:
        The heartbeat.

      • getHeartbeatOrBuilder

        HeartbeatOrBuilder getHeartbeatOrBuilder()
         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

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

      • getAck

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

      • getAckOrBuilder

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

      • hasTopologyChange

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

      • getTopologyChange

        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;
        Returns:
        The topologyChange.

      • getTopologyChangeOrBuilder

        TopologyChangeOrBuilder getTopologyChangeOrBuilder()
         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

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