diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 22:24:01 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 22:24:01 +0100 |
commit | c4d404e2b40d57bb46387aea777c722d894eaf84 (patch) | |
tree | c4e4d7653db6f8cff2e574e04749fb713b3d0e46 /messagebus/src | |
parent | 1fda1d9542a55a25168816f59a0e82405d8b4ae6 (diff) |
Use EmptyReply and SwapState.
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 24 |
1 files changed, 7 insertions, 17 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 3858a587fdf..faf8514df93 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -201,7 +201,7 @@ public final class SourceSession implements ReplyHandler { if (msg.isExpired()) { Error error = new Error(ErrorCode.TIMEOUT, "Timed out in sendQ"); notifyComplete(new Result(error)); - replyHandler.handleReply(new SendTimeoutReply(msg, error)); + replyHandler.handleReply(createSendTimedoutReply(msg, error)); return true; } return false; @@ -229,22 +229,12 @@ public final class SourceSession implements ReplyHandler { } } - static class SendTimeoutReply extends Reply { - - SendTimeoutReply(Message msg, Error error) { - setMessage(msg); - addError(error); - } - - @Override - public Utf8String getProtocol() { - return null; - } - - @Override - public int getType() { - return 0; - } + Reply createSendTimedoutReply(Message msg, Error error) { + Reply reply = new EmptyReply(); + reply.setMessage(msg); + reply.addError(error); + msg.swapState(reply); + return reply; } static private boolean isSendQFull(Result res) { |