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

Packages that use PlatformInboundInstruction

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

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

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

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

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

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

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

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

Uses of PlatformInboundInstruction in org.axonframework.axonserver.connector

Methods in org.axonframework.axonserver.connector that return types with arguments of type PlatformInboundInstruction

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.

Methods in org.axonframework.axonserver.connector with parameters of type PlatformInboundInstruction

Modifier and Type	Method and Description
void	AxonServerConnectionManager.send(String context, PlatformInboundInstruction instruction) Send the given instruction for given context to AxonServer.

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

Modifier and Type	Method and Description
AxonServerConnectionManager.Builder	AxonServerConnectionManager.Builder.instructionAckSource(InstructionAckSource<PlatformInboundInstruction> instructionAckSource) Sets the instruction ack source used to send instruction acknowledgements.
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(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.
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.

Uses of PlatformInboundInstruction in org.axonframework.axonserver.connector.processor.grpc

Methods in org.axonframework.axonserver.connector.processor.grpc that return PlatformInboundInstruction

Modifier and Type	Method and Description
PlatformInboundInstruction	PlatformInboundMessage.instruction() Supply a PlatformInboundInstruction.
PlatformInboundInstruction	TrackingEventProcessorInfoMessage.instruction()
PlatformInboundInstruction	SubscribingEventProcessorInfoMessage.instruction()