diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-02 13:34:35 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-02 13:35:00 +0200 |
commit | 2681f372b3f7d6f1c7504a032b5cd5692afbfb88 (patch) | |
tree | 47dca3e090880d40c79dffdbc2412824b1eb26e3 /src/main/java/com/orbekk/protobuf/RequestDispatcher.java | |
parent | 3fe83ccffdf53569f7d09af669cf8abaee95db15 (diff) |
Error handling.
Try to report failures locally instead of causing failures remotely.
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/RequestDispatcher.java')
-rw-r--r-- | src/main/java/com/orbekk/protobuf/RequestDispatcher.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RequestDispatcher.java b/src/main/java/com/orbekk/protobuf/RequestDispatcher.java index c9f79fb..4399a6e 100644 --- a/src/main/java/com/orbekk/protobuf/RequestDispatcher.java +++ b/src/main/java/com/orbekk/protobuf/RequestDispatcher.java @@ -47,6 +47,11 @@ public class RequestDispatcher extends Thread { private final RpcCallback<Message> callback = new RpcCallback<Message>() { @Override public void run(Message responseMessage) { + if (responseMessage == null && rpc.isOk()) { + throw new IllegalStateException( + "responseMessage is null, but rpc is ok: " + + rpc); + } if (responseMessage != null) { response.setResponseProto(responseMessage.toByteString()); } |