summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-05-01 11:22:24 +0200
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-05-01 11:22:24 +0200
commit0c7dd0f74b0abcf110670d450eb69e62b54b90af (patch)
treec14776658778fd671831b2cd6b8805f0ffd03eb0
parent01d0993aa195fbdc2a01591ffb059d8e6917ba68 (diff)
Fix(1): Set the correct response id when errors occur.
Fixes https://github.com/orbekk/protobuf-simple-rpc/issues/1.
-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);
}