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

Interface StreamRequestOrBuilder

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

    • Method Detail

      • hasOpen

        boolean hasOpen()
         the initial message to connect to a stream
        .io.axoniq.axonserver.grpc.streams.Open open = 1;
        Returns:
        Whether the open field is set.

      • getOpen

        Open getOpen()
         the initial message to connect to a stream
        .io.axoniq.axonserver.grpc.streams.Open open = 1;
        Returns:
        The open.

      • getOpenOrBuilder

        OpenOrBuilder getOpenOrBuilder()
         the initial message to connect to a stream
        .io.axoniq.axonserver.grpc.streams.Open open = 1;

      • hasAcknowledgeProgress

        boolean hasAcknowledgeProgress()
         sends progress in processing events to Axon Server
        .io.axoniq.axonserver.grpc.streams.ProgressAcknowledgement acknowledgeProgress = 2;
        Returns:
        Whether the acknowledgeProgress field is set.

      • getAcknowledgeProgress

        ProgressAcknowledgement getAcknowledgeProgress()
         sends progress in processing events to Axon Server
        .io.axoniq.axonserver.grpc.streams.ProgressAcknowledgement acknowledgeProgress = 2;
        Returns:
        The acknowledgeProgress.

      • getAcknowledgeProgressOrBuilder

        ProgressAcknowledgementOrBuilder getAcknowledgeProgressOrBuilder()
         sends progress in processing events to Axon Server
        .io.axoniq.axonserver.grpc.streams.ProgressAcknowledgement acknowledgeProgress = 2;

      • hasRequests

        boolean hasRequests()
         request a number of messages for a segment
        .io.axoniq.axonserver.grpc.streams.Requests requests = 3;
        Returns:
        Whether the requests field is set.

      • getRequests

        Requests getRequests()
         request a number of messages for a segment
        .io.axoniq.axonserver.grpc.streams.Requests requests = 3;
        Returns:
        The requests.

      • getRequestsOrBuilder

        RequestsOrBuilder getRequestsOrBuilder()
         request a number of messages for a segment
        .io.axoniq.axonserver.grpc.streams.Requests requests = 3;

      • hasError

        boolean hasError()
         notifies an error
        .io.axoniq.axonserver.grpc.streams.SegmentError error = 4;
        Returns:
        Whether the error field is set.

      • getError

        SegmentError getError()
         notifies an error
        .io.axoniq.axonserver.grpc.streams.SegmentError error = 4;
        Returns:
        The error.

      • getErrorOrBuilder

        SegmentErrorOrBuilder getErrorOrBuilder()
         notifies an error
        .io.axoniq.axonserver.grpc.streams.SegmentError error = 4;