diff options
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 4 |
1 files changed, 2 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 6f8e0903e9b..12ec4186513 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -176,7 +176,7 @@ public final class SourceSession implements ReplyHandler { try { blockedCount++; while (!closed && !throttlePolicy.canSend(msg, pendingCount)) { - lock.wait(100); + lock.wait(10); } } finally { blockedCount--; @@ -198,7 +198,7 @@ public final class SourceSession implements ReplyHandler { throttlePolicy.processReply(reply); } done = (closed && pendingCount == 0); - if (blockedCount < 100) { + if (blockedCount < 10) { lock.notifyAll(); } else { lock.notify(); |