summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/main/java/com/orbekk/protobuf/RequestDispatcher.java2
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);
}