Compare commits
2 Commits
860bd29ec2
...
3d3ea851a6
Author | SHA1 | Date | |
---|---|---|---|
3d3ea851a6 | |||
938f2821fd |
@ -3,14 +3,6 @@ type: docker
|
|||||||
name: default
|
name: default
|
||||||
|
|
||||||
steps:
|
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
|
- name: build_application
|
||||||
image: openjdk:11-jdk
|
image: openjdk:11-jdk
|
||||||
commands:
|
commands:
|
||||||
|
@ -2,7 +2,7 @@ import org.eclipse.paho.client.mqttv3.*
|
|||||||
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
|
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
|
||||||
import java.time.Instant
|
import java.time.Instant
|
||||||
|
|
||||||
class MqttSubscriber() : MqttCallbackExtended {
|
class MqttSubscriber : MqttCallbackExtended {
|
||||||
private val broker = System.getenv("BROKER") ?: "tcp://mqtt.k8s.kmlabz.com:1883"
|
private val broker = System.getenv("BROKER") ?: "tcp://mqtt.k8s.kmlabz.com:1883"
|
||||||
private val clientId = MqttClient.generateClientId()
|
private val clientId = MqttClient.generateClientId()
|
||||||
private val persistence = MemoryPersistence()
|
private val persistence = MemoryPersistence()
|
||||||
|
@ -14,5 +14,5 @@ fun main() = runBlocking{
|
|||||||
resultProcessor.mapToProcess=resultMap
|
resultProcessor.mapToProcess=resultMap
|
||||||
resultProcessor.process()
|
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.Instant
|
||||||
import java.time.ZoneId
|
import java.time.ZoneId
|
||||||
import java.time.format.DateTimeFormatter
|
import java.time.format.DateTimeFormatter
|
||||||
|
Loading…
Reference in New Issue
Block a user