From 99c239436d5792e67b6b2d02daa938186f6cb4a3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <post@soeren-henning.de>
Date: Fri, 8 May 2020 08:37:02 +0200
Subject: [PATCH] Remove sysout
---
.../src/main/java/uc3/workloadGenerator/LoadGenerator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java b/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
index 35b9ffdf2..d14d53f6c 100644
--- a/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
+++ b/uc3-workload-generator/src/main/java/uc3/workloadGenerator/LoadGenerator.java
@@ -61,13 +61,14 @@ public class LoadGenerator {
final ScheduledExecutorService executor = Executors.newScheduledThreadPool(threads);
final Random random = new Random();
+ LOGGER.info("Start setting up sensors.");
for (final String sensor : sensors) {
- System.out.println("working");
final int initialDelay = random.nextInt(periodMs);
executor.scheduleAtFixedRate(() -> {
kafkaRecordSender.write(new ActivePowerRecord(sensor, System.currentTimeMillis(), value));
}, initialDelay, periodMs, TimeUnit.MILLISECONDS);
}
+ LOGGER.info("Finished setting up sensors.");
System.out.println("Wait for termination...");
executor.awaitTermination(30, TimeUnit.DAYS);
--
GitLab