Uses of Class
io.axoniq.axonserver.grpc.control.PlatformOutboundInstruction

Packages that use PlatformOutboundInstruction

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

Uses of PlatformOutboundInstruction in io.axoniq.axonserver.grpc.control

Methods in io.axoniq.axonserver.grpc.control that return PlatformOutboundInstruction

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

Methods in io.axoniq.axonserver.grpc.control that return types with arguments of type PlatformOutboundInstruction

Modifier and Type	Method and Description
static io.grpc.MethodDescriptor<PlatformInboundInstruction,PlatformOutboundInstruction>	PlatformServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<PlatformOutboundInstruction>	PlatformOutboundInstruction.getParserForType()
static com.google.protobuf.Parser<PlatformOutboundInstruction>	PlatformOutboundInstruction.parser()

Methods in io.axoniq.axonserver.grpc.control with parameters of type PlatformOutboundInstruction

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

Method parameters in io.axoniq.axonserver.grpc.control with type arguments of type PlatformOutboundInstruction

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<PlatformInboundInstruction>	PlatformServiceGrpc.PlatformServiceImplBase.openStream(io.grpc.stub.StreamObserver<PlatformOutboundInstruction> responseObserver) Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application
io.grpc.stub.StreamObserver<PlatformInboundInstruction>	PlatformServiceGrpc.PlatformServiceStub.openStream(io.grpc.stub.StreamObserver<PlatformOutboundInstruction> responseObserver) Opens an instruction stream to the Platform, allowing AxonServer to provide management instructions to the application

Uses of PlatformOutboundInstruction in org.axonframework.axonserver.connector

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

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<PlatformInboundInstruction>	AxonServerConnectionManager.getPlatformStream(String context, io.grpc.stub.StreamObserver<PlatformOutboundInstruction> outboundInstructionStream) Opens a Stream for platform instructions in given context.
void	AxonServerConnectionManager.onOutboundInstruction(BiConsumer<PlatformOutboundInstruction,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> handler) Registers a handler to handle instructions from AxonServer.
void	AxonServerConnectionManager.onOutboundInstruction(BiPredicate<String,PlatformOutboundInstruction.RequestCase> handlerSelector, BiConsumer<PlatformOutboundInstruction,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> handler) Registers a handler to handle instructions from AxonServer.
void	AxonServerConnectionManager.onOutboundInstruction(PlatformOutboundInstruction.RequestCase requestCase, BiConsumer<PlatformOutboundInstruction,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> handler) Registers a handler to handle instructions from AxonServer.
void	AxonServerConnectionManager.onOutboundInstruction(PlatformOutboundInstruction.RequestCase requestCase, Consumer<PlatformOutboundInstruction> consumer) Deprecated. in favor of AxonServerConnectionManager.onOutboundInstruction(String, PlatformOutboundInstruction.RequestCase, Consumer) as the context should be specified on any outbound instruction
void	AxonServerConnectionManager.onOutboundInstruction(String context, BiConsumer<PlatformOutboundInstruction,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> handler) Registers a handler to handle instructions from AxonServer.
void	AxonServerConnectionManager.onOutboundInstruction(String context, PlatformOutboundInstruction.RequestCase requestCase, BiConsumer<PlatformOutboundInstruction,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> handler) Registers a handler to handle instructions from AxonServer.
void	AxonServerConnectionManager.onOutboundInstruction(String context, PlatformOutboundInstruction.RequestCase requestCase, Consumer<PlatformOutboundInstruction> consumer) Registers a handler to handle instructions from AxonServer.
AxonServerConnectionManager.Builder	AxonServerConnectionManager.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<PlatformOutboundInstruction>,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.