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 35b9ffdf261276b4b409d093c5e02c7ada48d662..d14d53f6cdbe81d9cddedeba8f484dea26571654 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);