Newer
Older
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();
responseObserver.onNext(Hello.HelloReply.newBuilder().setMessage(message).build());
responseObserver.onCompleted();
}
}