Skip to content
Snippets Groups Projects
Commit 5aed17b7 authored by Sören Henning's avatar Sören Henning
Browse files

Minor code clean up

parent 1af90ac2
No related branches found
No related tags found
1 merge request!33Fix workload generation for benchmark UC2
Pipeline #827 passed
...@@ -100,11 +100,8 @@ public abstract class AbstractWorkloadGenerator<T> ...@@ -100,11 +100,8 @@ public abstract class AbstractWorkloadGenerator<T>
entities.forEach(entity -> { entities.forEach(entity -> {
final T message = entity.generateMessage(); final T message = entity.generateMessage();
final long initialDelay = random.nextInt(periodMs); final long initialDelay = random.nextInt(periodMs);
final Runnable task = () -> { final Runnable task = () -> this.transport.transport(message);
this.transport.transport(message); this.executor.scheduleAtFixedRate(task, initialDelay, periodMs, TimeUnit.MILLISECONDS);
};
this.executor.scheduleAtFixedRate(task, initialDelay,
periodMs, TimeUnit.MILLISECONDS);
}); });
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment