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

Class PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub

  • Enclosing class:
    PersistentStreamServiceGrpc
    public static final class PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub>
    A stub to allow clients to do synchronous rpc calls to service PersistentStreamService. 
     Service providing operations for persistent event streams, event streams where Axon Server keeps
track of the progress. All operations require a header (AxonIQ-Context) to be passed with each request to define
the context.

    • Method Detail

      • createStream

        public CreateStreamResponse createStream​(CreateStreamRequest request)
                                  throws io.grpc.StatusException
         Creates a persistent stream if it does not exist.
        Throws:
        io.grpc.StatusException

      • openStream

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<StreamRequest,​StreamSignal> openStream()
         Open a persistent event stream connection from a client. Creates the stream if it does not exist.

      • deleteStream

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​com.google.protobuf.Empty> deleteStream​(DeleteStreamRequest request)
         Deletes a persistent event stream. All existing connections to the stream are closed.

      • updateStream

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​com.google.protobuf.Empty> updateStream​(UpdateStreamRequest request)
         Change properties of a persistent event stream.

      • listStreams

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​StreamStatus> listStreams​(ListStreamsRequest request)
         Returns a list of all persistent event streams defined (for the context). For each event stream it returns
the progress per segment.

      • resetStream

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​com.google.protobuf.Empty> resetStream​(ResetStreamRequest request)
         Resets the position of a persistent stream.