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

Interface StreamSignalOrBuilder

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

    • Method Detail

      • getSegment

        int getSegment()
         the segment number
        int32 segment = 1;
        Returns:
        The segment.

      • hasEvent

        boolean hasEvent()
         an event to process in the client
        .io.axoniq.axonserver.grpc.streams.PersistentStreamEvent event = 2;
        Returns:
        Whether the event field is set.

      • getEvent

        PersistentStreamEvent getEvent()
         an event to process in the client
        .io.axoniq.axonserver.grpc.streams.PersistentStreamEvent event = 2;
        Returns:
        The event.

      • getEventOrBuilder

        PersistentStreamEventOrBuilder getEventOrBuilder()
         an event to process in the client
        .io.axoniq.axonserver.grpc.streams.PersistentStreamEvent event = 2;

      • hasClosed

        boolean hasClosed()
         indicates that the segment is closed by Axon Server
        bool closed = 3;
        Returns:
        Whether the closed field is set.

      • getClosed

        boolean getClosed()
         indicates that the segment is closed by Axon Server
        bool closed = 3;
        Returns:
        The closed.

      • hasOpen

        boolean hasOpen()
         segment assigned to the client
        .io.axoniq.axonserver.grpc.streams.OpenSegment open = 4;
        Returns:
        Whether the open field is set.

      • getOpen

        OpenSegment getOpen()
         segment assigned to the client
        .io.axoniq.axonserver.grpc.streams.OpenSegment open = 4;
        Returns:
        The open.

      • getOpenOrBuilder

        OpenSegmentOrBuilder getOpenOrBuilder()
         segment assigned to the client
        .io.axoniq.axonserver.grpc.streams.OpenSegment open = 4;