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 2f2d823463b0e68ce8b8b0cbf373cbb9cd049870..7f372e014371e5407374493b6aced3bf949a1674 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
@@ -100,11 +100,8 @@ public abstract class AbstractWorkloadGenerator<T>
       entities.forEach(entity -> {
         final T message = entity.generateMessage();
         final long initialDelay = random.nextInt(periodMs);
-        final Runnable task = () -> {
-          this.transport.transport(message);
-        };
-        this.executor.scheduleAtFixedRate(task, initialDelay,
-            periodMs, TimeUnit.MILLISECONDS);
+        final Runnable task = () -> this.transport.transport(message);
+        this.executor.scheduleAtFixedRate(task, initialDelay, periodMs, TimeUnit.MILLISECONDS);
       });