upload to docker hub

.drone.yml

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