summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-11 15:34:17 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-11 15:34:17 +0200
commitb9ee732beb495e1ee6b1fb6770d754a7228155ba (patch)
treed40abe19d8b5d81955bc04910432519c919a7531 /messagebus
parentaccba940ad0884d4f52880f75a7509f60908ab84 (diff)
Check for retries at least every 10ms when no replies, as opposed to every 100ms.
Diffstat (limited to 'messagebus')
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/Messenger.java8
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 {