From 1ff31ed08c398a1791adf11f5160e2905aa9038b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <post@soeren-henning.de>
Date: Sun, 13 Sep 2020 00:49:52 +0200
Subject: [PATCH] Fix bug of always sending the same message
---
.../generators/AbstractWorkloadGenerator.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/generators/AbstractWorkloadGenerator.java b/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/generators/AbstractWorkloadGenerator.java
index 7f372e014..104f1cefb 100644
--- a/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/generators/AbstractWorkloadGenerator.java
+++ b/workload-generator-commons/src/main/java/theodolite/commons/workloadgeneration/generators/AbstractWorkloadGenerator.java
@@ -98,9 +98,8 @@ public abstract class AbstractWorkloadGenerator<T>
LOGGER.info("Experiment is going to be executed for the specified duration...");
entities.forEach(entity -> {
- final T message = entity.generateMessage();
final long initialDelay = random.nextInt(periodMs);
- final Runnable task = () -> this.transport.transport(message);
+ final Runnable task = () -> this.transport.transport(entity.generateMessage());
this.executor.scheduleAtFixedRate(task, initialDelay, periodMs, TimeUnit.MILLISECONDS);
});
--
GitLab