Merge pull request #401 from rabbitmq/millisecond-for-ramp-up-period

Use millisecond granularity for publisher ramp-up period
rabbitmq · Oct 5, 2022 · c56dabf · c56dabf
2 parents b0772a8 + 67929a6
commit c56dabf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/com/rabbitmq/perf/MulticastSet.java b/src/main/java/com/rabbitmq/perf/MulticastSet.java
@@ -456,8 +456,9 @@ PRODUCER_THREAD_PREFIX, nbThreadsForProducerScheduledExecutorService(params)
             Supplier<Duration> startDelaySupplier;
             if (params.getProducerRandomStartDelayInSeconds() > 0) {
                 Random random = new Random();
-                startDelaySupplier = () -> Duration.ofSeconds(
-                    random.nextInt(params.getProducerRandomStartDelayInSeconds()) + 1
+                int bound = params.getProducerRandomStartDelayInSeconds() * 1000;
+                startDelaySupplier = () -> Duration.ofMillis(
+                    random.nextInt(bound) + 1
                 );
             } else {
                 startDelaySupplier = () -> Duration.ZERO;