io.axoniq.axonserver.grpc.command

Class CommandServiceGrpc.CommandServiceImplBase

java.lang.Object

io.axoniq.axonserver.grpc.command.CommandServiceGrpc.CommandServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

CommandServiceGrpc

public abstract static class CommandServiceGrpc.CommandServiceImplBase
extends Object
implements io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor and Description
CommandServiceImplBase()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandServiceImplBase

public CommandServiceImplBase()

Method Detail

openStream

public 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

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

 Dispatches the given command, returning the result of command execution 
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService