overflow_backup_2018_0455/overflow_server
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed

Browse Source 
servcice Proxy
This commit is contained in:
snoop 2017-06-30 15:04:40 +09:00
parent 05fd997c81
commit 6d6f93cdee
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/loafle/overflow/proxy/ServiceProxy.java
View File

@ -67,6 +67,12 @@ public class ServiceProxy {
String result = null; String result = null;
try { try {
result =this.serviceInvoker.invokeForByteString(request.getTarget(), request.getMethod(), request.getParamsList().asByteStringList()); result =this.serviceInvoker.invokeForByteString(request.getTarget(), request.getMethod(), request.getParamsList().asByteStringList());
ServerOutput reply = ServerOutput.newBuilder()
.setResult(result)
.build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
} catch (NoSuchMethodException e) { } catch (NoSuchMethodException e) {
e.printStackTrace(); e.printStackTrace();
responseObserver.onError(e); responseObserver.onError(e);
@ -83,11 +89,7 @@ public class ServiceProxy {
e.printStackTrace(); e.printStackTrace();
responseObserver.onError(e); responseObserver.onError(e);
} }
ServerOutput reply = ServerOutput.newBuilder()
.setResult(result)
.build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
// String targetServiceName = request.getTarget(); // String targetServiceName = request.getTarget();
// Object service = ctx.getBean(targetServiceName); // Object service = ctx.getBean(targetServiceName);