diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 13:21:11 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 13:21:11 +0100 |
commit | 05a7c3b134d1d5242a5499b06547749ad28e613e (patch) | |
tree | 875215b42c93f50a7ad6ff6ab02eecc20b3b0089 /messagebus | |
parent | 40f1e5901f32d2c6ae44be1c48e1ab2ae15658ab (diff) |
Avoid double negation.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 916a0ef6e6e..ad2f16f35ed 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -132,7 +132,6 @@ public final class SourceSession implements ReplyHandler, Runnable { * @return The result of <i>initiating</i> sending of this message. */ public Result send(Message msg) { - return sendInternal(updateTiming(msg)); } private Message updateTiming(Message msg) { @@ -254,7 +253,7 @@ public final class SourceSession implements ReplyHandler, Runnable { } static private boolean isSendQFull(Result res) { - return ! (res.isAccepted() || res.getError().getCode() != ErrorCode.SEND_QUEUE_FULL); + return !res.isAccepted() && (res.getError().getCode() == ErrorCode.SEND_QUEUE_FULL); } /** |