diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-01 11:22:24 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-01 11:22:24 +0200 |
commit | 0c7dd0f74b0abcf110670d450eb69e62b54b90af (patch) | |
tree | c14776658778fd671831b2cd6b8805f0ffd03eb0 | |
parent | 01d0993aa195fbdc2a01591ffb059d8e6917ba68 (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.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); } |