Repository: camel Updated Branches: refs/heads/master 1d0a97ca8 -> b0c7e793d
Fixed test Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/960adc23 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/960adc23 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/960adc23 Branch: refs/heads/master Commit: 960adc23fd8096e66042c6d66e467249c8517df0 Parents: b7ffeac Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Feb 15 08:54:28 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Feb 15 09:27:23 2016 +0100 ---------------------------------------------------------------------- .../test/java/org/apache/camel/processor/ThrottlerTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/960adc23/camel-core/src/test/java/org/apache/camel/processor/ThrottlerTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/ThrottlerTest.java b/camel-core/src/test/java/org/apache/camel/processor/ThrottlerTest.java index c0ae2f5..e4dd502 100644 --- a/camel-core/src/test/java/org/apache/camel/processor/ThrottlerTest.java +++ b/camel-core/src/test/java/org/apache/camel/processor/ThrottlerTest.java @@ -149,9 +149,9 @@ public class ThrottlerTest extends ContextTestSupport { } private void assertThrottlerTiming(final long elapsedTimeMs, final int throttle, final int intervalMs, final int messageCount) { - // now assert that they have actually been throttled - long minimum = calculateMinimum(intervalMs, throttle, messageCount); - long maximum = calculateMaximum(intervalMs, throttle, messageCount); + // now assert that they have actually been throttled (use +/- 50 as slack) + long minimum = calculateMinimum(intervalMs, throttle, messageCount) - 50; + long maximum = calculateMaximum(intervalMs, throttle, messageCount) + 50; log.info("Sent {} exchanges in {}ms, with throttle rate of {} per {}ms. Calculated min {}ms and max {}ms", new Object[]{messageCount, elapsedTimeMs, throttle, intervalMs, minimum, maximum}); assertTrue("Should take at least " + minimum + "ms, was: " + elapsedTimeMs, elapsedTimeMs >= minimum);
