upload to docker hub

.drone.yml

@@ -1,39 +1,43 @@
-kind: pipeline
+kind: pipeline
-type: docker
+type: docker
-name: default
+name: default
-
+
-steps:
+steps:
-  - name: code-analysis
+  - name: build_application
-    image: aosapps/drone-sonar-plugin
+    image: openjdk:11-jdk
-    settings:
+    commands:
-      sonar_host:
+      - chmod +x gradlew
-        from_secret: SONAR_HOST
+      - ./gradlew build -x test
-      sonar_token:
+
-        from_secret: SONAR_CODE
+  - name: kaniko
-
+    image: banzaicloud/drone-kaniko
-  - name: build_application
+    settings:
-    image: openjdk:11-jdk
+      registry: registry.kmlabz.com
-    commands:
+      repo: birbnetes/${DRONE_REPO_NAME}
-      - chmod +x gradlew
+      username:
-      - ./gradlew build -x test
+        from_secret: DOCKER_USERNAME
-
+      password:
-  - name: kaniko
+        from_secret: DOCKER_PASSWORD
-    image: banzaicloud/drone-kaniko
+      tags:
-    settings:
+        - latest
-      registry: registry.kmlabz.com
+        - ${DRONE_BUILD_NUMBER}
-      repo: birbnetes/${DRONE_REPO_NAME}
+
-      username:
+  - name: dockerhub
-        from_secret: DOCKER_USERNAME
+    image: plugins/docker
-      password:
+    settings:
-        from_secret: DOCKER_PASSWORD
+      repo: birbnetes/${DRONE_REPO_NAME}
-      tags:
+      username:
-        - latest
+        from_secret: DOCKERHUB_USER
-        - ${DRONE_BUILD_NUMBER}
+      password:
-
+        from_secret: DOCKERHUB_PASSWORD
-  - name: ms-teams
+      tags:
-    image: kuperiu/drone-teams
+        - latest
-    settings:
+        - ${DRONE_BUILD_NUMBER}
-      webhook:
+
-        from_secret: TEAMS_WEBHOOK
+  - name: ms-teams
-    when:
+    image: kuperiu/drone-teams
-      status: [ failure ]
+    settings:
+      webhook:
+        from_secret: TEAMS_WEBHOOK
+    when:
+      status: [ failure, changed ]

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()

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)
 }

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