summaryrefslogtreecommitdiffstats
path: root/messagebus/src/test
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-12 15:46:04 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-12 15:46:04 +0200
commit751002293a4bb389c7db69a3af28b467c0f55478 (patch)
treeae2ef16f431495de3a577a1a7806dc98ca437d60 /messagebus/src/test
parenta9e3a26a04f795c20b4ed6ca3f8731b3fbcbe73f (diff)
A collection of code cleanup in messagebus. And a bonus of catching missing shutdown of config subscription.
Diffstat (limited to 'messagebus/src/test')
-rw-r--r--messagebus/src/test/java/com/yahoo/messagebus/ThrottlerTestCase.java14
1 files changed, 7 insertions, 7 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/ThrottlerTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/ThrottlerTestCase.java
index 432524ea2a9..f6185f1d410 100644
--- a/messagebus/src/test/java/com/yahoo/messagebus/ThrottlerTestCase.java
+++ b/messagebus/src/test/java/com/yahoo/messagebus/ThrottlerTestCase.java
@@ -133,8 +133,8 @@ public class ThrottlerTestCase {
CustomTimer timer = new CustomTimer();
DynamicThrottlePolicy policy = new DynamicThrottlePolicy(timer);
- policy.setWindowSizeIncrement(5);
- policy.setResizeRate(1);
+ policy.setWindowSizeIncrement(5)
+ .setResizeRate(1);
double windowSize = getWindowSize(policy, timer, 100);
assertTrue(windowSize >= 90 && windowSize <= 110);
@@ -157,8 +157,8 @@ public class ThrottlerTestCase {
CustomTimer timer = new CustomTimer();
DynamicThrottlePolicy policy = new DynamicThrottlePolicy(timer);
- policy.setWindowSizeIncrement(5);
- policy.setResizeRate(1);
+ policy.setWindowSizeIncrement(5)
+ .setResizeRate(1);
double windowSize = getWindowSize(policy, timer, 100);
assertTrue(windowSize >= 90 && windowSize <= 110);
@@ -183,9 +183,9 @@ public class ThrottlerTestCase {
CustomTimer timer = new CustomTimer();
DynamicThrottlePolicy policy = new DynamicThrottlePolicy(timer);
- policy.setWindowSizeIncrement(5);
- policy.setResizeRate(1);
- policy.setMinWindowSize(150);
+ policy.setWindowSizeIncrement(5)
+ .setResizeRate(1)
+ .setMinWindowSize(150);
double windowSize = getWindowSize(policy, timer, 200);
assertTrue(windowSize >= 150 && windowSize <= 210);