proxy server

This commit is contained in:
insanity 2017-06-28 19:09:13 +09:00
parent 10d4f8a966
commit cf32ecc88e

View File

@ -23,12 +23,14 @@ public class ServiceProxy {
private static final Logger logger = Logger.getLogger(ServiceProxy.class.getName());
private io.grpc.Server server;
public static ApplicationContext ctx;
public ServiceProxy() {
}
public void start(int port) throws IOException {
ctx = new AnnotationConfigApplicationContext("com.loafle.overflow");
server = ServerBuilder.forPort(port)
.addService(new ServiceImpl())
.build()
@ -61,7 +63,7 @@ public class ServiceProxy {
@Override
public void exec(ServerInput request,
io.grpc.stub.StreamObserver<ServerOutput> responseObserver) {
ApplicationContext ctx = new AnnotationConfigApplicationContext("com.loafle.overflow");
String targetServiceName = request.getTarget();
Object service = ctx.getBean(targetServiceName);