Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.streams

Class PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub>

io.axoniq.axonserver.grpc.streams.PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub

Enclosing class:

PersistentStreamServiceGrpc

public static final class PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.PersistentStreamServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<CreateStreamResponse>	createStream(CreateStreamRequest request)	Creates a persistent stream if it does not exist.

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.PersistentStreamServiceFutureStub build(io.grpc.Channel channel,
                                                                              io.grpc.CallOptions callOptions)

Specified by:

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

createStream

public com.google.common.util.concurrent.ListenableFuture<CreateStreamResponse> createStream(CreateStreamRequest request)

 Creates a persistent stream if it does not exist.