Uses of Class
io.axoniq.axonserver.grpc.command.CommandProviderInbound

Packages that use CommandProviderInbound

Package	Description
io.axoniq.axonserver.grpc.command
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.command

Uses of CommandProviderInbound in io.axoniq.axonserver.grpc.command

Methods in io.axoniq.axonserver.grpc.command that return CommandProviderInbound

Modifier and Type	Method and Description
CommandProviderInbound	CommandProviderInbound.Builder.build()
CommandProviderInbound	CommandProviderInbound.Builder.buildPartial()
static CommandProviderInbound	CommandProviderInbound.getDefaultInstance()
CommandProviderInbound	CommandProviderInbound.getDefaultInstanceForType()
CommandProviderInbound	CommandProviderInbound.Builder.getDefaultInstanceForType()
static CommandProviderInbound	CommandProviderInbound.parseDelimitedFrom(InputStream input)
static CommandProviderInbound	CommandProviderInbound.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CommandProviderInbound	CommandProviderInbound.parseFrom(byte[] data)
static CommandProviderInbound	CommandProviderInbound.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CommandProviderInbound	CommandProviderInbound.parseFrom(ByteBuffer data)
static CommandProviderInbound	CommandProviderInbound.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CommandProviderInbound	CommandProviderInbound.parseFrom(com.google.protobuf.ByteString data)
static CommandProviderInbound	CommandProviderInbound.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CommandProviderInbound	CommandProviderInbound.parseFrom(com.google.protobuf.CodedInputStream input)
static CommandProviderInbound	CommandProviderInbound.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static CommandProviderInbound	CommandProviderInbound.parseFrom(InputStream input)
static CommandProviderInbound	CommandProviderInbound.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.command that return types with arguments of type CommandProviderInbound

Modifier and Type	Method and Description
static io.grpc.MethodDescriptor<CommandProviderOutbound,CommandProviderInbound>	CommandServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<CommandProviderInbound>	CommandProviderInbound.getParserForType()
static com.google.protobuf.Parser<CommandProviderInbound>	CommandProviderInbound.parser()

Methods in io.axoniq.axonserver.grpc.command with parameters of type CommandProviderInbound

Modifier and Type	Method and Description
CommandProviderInbound.Builder	CommandProviderInbound.Builder.mergeFrom(CommandProviderInbound other)
static CommandProviderInbound.Builder	CommandProviderInbound.newBuilder(CommandProviderInbound prototype)

Method parameters in io.axoniq.axonserver.grpc.command with type arguments of type CommandProviderInbound

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<CommandProviderOutbound>	CommandServiceGrpc.CommandServiceImplBase.openStream(io.grpc.stub.StreamObserver<CommandProviderInbound> responseObserver) Opens a stream allowing clients to register command handlers and receive commands.
io.grpc.stub.StreamObserver<CommandProviderOutbound>	CommandServiceGrpc.CommandServiceStub.openStream(io.grpc.stub.StreamObserver<CommandProviderInbound> responseObserver) Opens a stream allowing clients to register command handlers and receive commands.

Uses of CommandProviderInbound in org.axonframework.axonserver.connector

Method parameters in org.axonframework.axonserver.connector with type arguments of type CommandProviderInbound

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<CommandProviderOutbound>	AxonServerConnectionManager.getCommandStream(String context, io.grpc.stub.StreamObserver<CommandProviderInbound> inboundCommandStream) Opens a Stream for incoming commands from AxonServer in the given context.

Uses of CommandProviderInbound in org.axonframework.axonserver.connector.command

Method parameters in org.axonframework.axonserver.connector.command with type arguments of type CommandProviderInbound

Modifier and Type	Method and Description
AxonServerCommandBus.Builder	AxonServerCommandBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<CommandProviderInbound>,io.grpc.stub.StreamObserver<CommandProviderOutbound>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.