diff options
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/RequestDispatcher.java')
-rw-r--r-- | src/main/java/com/orbekk/protobuf/RequestDispatcher.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RequestDispatcher.java b/src/main/java/com/orbekk/protobuf/RequestDispatcher.java index b0a4600..6af6e5e 100644 --- a/src/main/java/com/orbekk/protobuf/RequestDispatcher.java +++ b/src/main/java/com/orbekk/protobuf/RequestDispatcher.java @@ -58,6 +58,7 @@ public class RequestDispatcher extends Thread { } public void internalRun() throws InterruptedException { + response.setRequestId(request.getRequestId()); Service service = services.get(request.getFullServiceName()); if (service == null) { response.setError(Data.Response.RpcError.UNKNOWN_SERVICE); @@ -90,7 +91,6 @@ public class RequestDispatcher extends Thread { method.getFullName(), requestMessage)); } - response.setRequestId(request.getRequestId()); service.callMethod(method, rpc, requestMessage, callback); } |