diff options
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); } /** |