HelloGrpcService.java

package cz.mendelu.grpc.server;

import grpc.sequence.GreeterGrpc;
import grpc.sequence.Hello;
import io.grpc.stub.StreamObserver;
import io.quarkus.grpc.GrpcService;

@GrpcService
public class HelloGrpcService extends GreeterGrpc.GreeterImplBase {

    @Override
    public void sayHello(Hello.HelloRequest request, StreamObserver<Hello.HelloReply> responseObserver) {
        String name = request.getName();
        String message = "Hello " + name;
        responseObserver.onNext(Hello.HelloReply.newBuilder().setMessage(message).build());
        responseObserver.onCompleted();
    }
}