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

Interface PlatformInboundInstructionOrBuilder

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

    • Method Detail

      • hasRegister

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

      • getRegister

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

      • getRegisterOrBuilder

        ClientIdentificationOrBuilder getRegisterOrBuilder()
         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

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

      • getEventProcessorInfo

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

      • getEventProcessorInfoOrBuilder

        EventProcessorInfoOrBuilder getEventProcessorInfoOrBuilder()
         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

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

      • getHeartbeat

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

      • getHeartbeatOrBuilder

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

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

      • getAck

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

      • getAckOrBuilder

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

      • hasResult

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

      • getResult

        InstructionResult getResult()
         The result of the execution of an instruction
        .io.axoniq.axonserver.grpc.InstructionResult result = 6;
        Returns:
        The result.

      • getResultOrBuilder

        InstructionResultOrBuilder getResultOrBuilder()
         The result of the execution of an instruction
        .io.axoniq.axonserver.grpc.InstructionResult result = 6;

      • hasSubscribeTopologyChanges

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

      • getSubscribeTopologyChanges

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

      • getSubscribeTopologyChangesOrBuilder

        SubscribeTopologyChangesOrBuilder getSubscribeTopologyChangesOrBuilder()
         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

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

      • getUnsubscribeTopologyChanges

        UnsubscribeTopologyChanges getUnsubscribeTopologyChanges()
         Unsubscribe from topology changes in the AxonServer cluster.
        .io.axoniq.axonserver.grpc.control.UnsubscribeTopologyChanges unsubscribe_topology_changes = 8;
        Returns:
        The unsubscribeTopologyChanges.

      • getUnsubscribeTopologyChangesOrBuilder

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

      • getInstructionId

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

      • getInstructionIdBytes

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