diff options
Diffstat (limited to 'src/main/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);          } | 
