Compare commits
2 Commits
860bd29ec2
...
3d3ea851a6
Author | SHA1 | Date | |
---|---|---|---|
3d3ea851a6 | |||
938f2821fd |
@ -3,14 +3,6 @@ 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:
|
||||
|
@ -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()
|
||||
|
@ -14,5 +14,5 @@ fun main() = runBlocking{
|
||||
resultProcessor.mapToProcess=resultMap
|
||||
resultProcessor.process()
|
||||
}
|
||||
delay(20000L)
|
||||
delay(System.getenv("WAITTIME").toLong()*2)
|
||||
}
|
@ -1,4 +1,3 @@
|
||||
import java.text.SimpleDateFormat
|
||||
import java.time.Instant
|
||||
import java.time.ZoneId
|
||||
import java.time.format.DateTimeFormatter
|
||||
|
Loading…
Reference in New Issue
Block a user