diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-11 15:34:17 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-11 15:34:17 +0200 |
commit | b9ee732beb495e1ee6b1fb6770d754a7228155ba (patch) | |
tree | d40abe19d8b5d81955bc04910432519c919a7531 /messagebus | |
parent | accba940ad0884d4f52880f75a7509f60908ab84 (diff) |
Check for retries at least every 10ms when no replies, as opposed to every 100ms.
Diffstat (limited to 'messagebus')
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/Messenger.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java index 4fb83386231..63e5dbb2d04 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java @@ -44,7 +44,7 @@ public class Messenger implements Runnable { * * @param task The task to add. */ - public void addRecurrentTask(final Task task) { + void addRecurrentTask(final Task task) { children.add(task); } @@ -159,7 +159,7 @@ public class Messenger implements Runnable { synchronized (this) { if (queue.isEmpty()) { try { - wait(100); + wait(10); } catch (final InterruptedException e) { continue; } @@ -210,13 +210,13 @@ public class Messenger implements Runnable { /** * <p>This method is called when being executed.</p> */ - public void run(); + void run(); /** * <p>This method is called for all tasks, even if {@link #run()} was * never called.</p> */ - public void destroy(); + void destroy(); } private static class MessageTask implements Runnable { |