Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.streams

Class PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub>

io.axoniq.axonserver.grpc.streams.PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub

Enclosing class:

PersistentStreamServiceGrpc

public static final class PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub>

A stub to allow clients to do limited 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.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CreateStreamResponse	createStream(CreateStreamRequest request)	Creates a persistent stream if it does not exist.
Iterator<com.google.protobuf.Empty>	deleteStream(DeleteStreamRequest request)	Deletes a persistent event stream.
Iterator<StreamStatus>	listStreams(ListStreamsRequest request)	Returns a list of all persistent event streams defined (for the context).
Iterator<com.google.protobuf.Empty>	resetStream(ResetStreamRequest request)	Resets the position of a persistent stream.
Iterator<com.google.protobuf.Empty>	updateStream(UpdateStreamRequest request)	Change properties of a persistent event stream.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub build(io.grpc.Channel channel,
                                                                                io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub>

createStream

public CreateStreamResponse createStream(CreateStreamRequest request)

 Creates a persistent stream if it does not exist. 
 

deleteStream

public Iterator<com.google.protobuf.Empty> deleteStream(DeleteStreamRequest request)

 Deletes a persistent event stream. All existing connections to the stream are closed. 
 

updateStream

public Iterator<com.google.protobuf.Empty> updateStream(UpdateStreamRequest request)

 Change properties of a persistent event stream. 
 

listStreams

public Iterator<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

public Iterator<com.google.protobuf.Empty> resetStream(ResetStreamRequest request)

 Resets the position of a persistent stream.