From 938f2821fd804f675ca4563482a34b7ce74ea999 Mon Sep 17 00:00:00 2001
From: Torma <tormakristof@tormakristof.eu>
Date: Thu, 22 Oct 2020 21:00:42 +0200
Subject: [PATCH] changed some changes

---
 src/main/kotlin/MQTTSubscriber.kt | 2 +-
 src/main/kotlin/Main.kt           | 2 +-
 src/main/kotlin/ProcessResults.kt | 1 -
 3 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/kotlin/MQTTSubscriber.kt b/src/main/kotlin/MQTTSubscriber.kt
index bed594f..a230ead 100644
--- a/src/main/kotlin/MQTTSubscriber.kt
+++ b/src/main/kotlin/MQTTSubscriber.kt
@@ -2,7 +2,7 @@ import org.eclipse.paho.client.mqttv3.*
 import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
 import java.time.Instant
 
-class MqttSubscriber() : MqttCallbackExtended {
+class MqttSubscriber : MqttCallbackExtended {
     private val broker = System.getenv("BROKER") ?: "tcp://mqtt.k8s.kmlabz.com:1883"
     private val clientId = MqttClient.generateClientId()
     private val persistence = MemoryPersistence()
diff --git a/src/main/kotlin/Main.kt b/src/main/kotlin/Main.kt
index bc09ab3..12e40ce 100644
--- a/src/main/kotlin/Main.kt
+++ b/src/main/kotlin/Main.kt
@@ -14,5 +14,5 @@ fun main() = runBlocking{
         resultProcessor.mapToProcess=resultMap
         resultProcessor.process()
     }
-    delay(20000L)
+    delay(System.getenv("WAITTIME").toLong()*2)
 }
\ No newline at end of file
diff --git a/src/main/kotlin/ProcessResults.kt b/src/main/kotlin/ProcessResults.kt
index 9858152..09ce83c 100644
--- a/src/main/kotlin/ProcessResults.kt
+++ b/src/main/kotlin/ProcessResults.kt
@@ -1,4 +1,3 @@
-import java.text.SimpleDateFormat
 import java.time.Instant
 import java.time.ZoneId
 import java.time.format.DateTimeFormatter