Class MessageServiceGrpc.MessageServiceImplBase

  • All Implemented Interfaces:
    io.grpc.BindableService
    Enclosing class:
    MessageServiceGrpc

    public abstract static class MessageServiceGrpc.MessageServiceImplBase
    extends Object
    implements io.grpc.BindableService
     A grpc service for implementing org.apache.nemo.runtime.common.message components using grpc
     
    • Constructor Detail

      • MessageServiceImplBase

        public MessageServiceImplBase()
    • Method Detail

      • request

        public void request​(ControlMessage.Message request,
                            io.grpc.stub.StreamObserver<ControlMessage.Message> responseObserver)
         See org.apache.nemo.runtime.common.message.MessageSender#request for more details
         
      • bindService

        public final io.grpc.ServerServiceDefinition bindService()
        Specified by:
        bindService in interface io.grpc.BindableService