Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.command

Interface CommandServiceGrpc.AsyncService

All Known Implementing Classes:

CommandServiceGrpc.CommandServiceImplBase

Enclosing class:

CommandServiceGrpc

public static interface CommandServiceGrpc.AsyncService

 The CommandService defines the gRPC requests necessary for subscribing command handlers, and dispatching commands. 
 

Method Summary

Modifier and Type	Method	Description
default void	dispatch(Command request, io.grpc.stub.StreamObserver<CommandResponse> responseObserver)	Dispatches the given command, returning the result of command execution
default io.grpc.stub.StreamObserver<CommandProviderOutbound>	openStream(io.grpc.stub.StreamObserver<CommandProviderInbound> responseObserver)	Opens a stream allowing clients to register command handlers and receive commands.

Method Detail

openStream

default io.grpc.stub.StreamObserver<CommandProviderOutbound> openStream(io.grpc.stub.StreamObserver<CommandProviderInbound> responseObserver)

 Opens a stream allowing clients to register command handlers and receive commands. 
 

dispatch

default void dispatch(Command request,
                      io.grpc.stub.StreamObserver<CommandResponse> responseObserver)

 Dispatches the given command, returning the result of command execution