aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-06 13:21:11 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-06 13:21:11 +0100
commit05a7c3b134d1d5242a5499b06547749ad28e613e (patch)
tree875215b42c93f50a7ad6ff6ab02eecc20b3b0089 /messagebus
parent40f1e5901f32d2c6ae44be1c48e1ab2ae15658ab (diff)
Avoid double negation.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java3
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);
}
/**