Compare commits
No commits in common. "3d3ea851a63bdee619cce9c394e34ac769734ab3" and "860bd29ec2323fbb4c5044e6ed3a7f75731f7055" have entirely different histories.
3d3ea851a6
...
860bd29ec2
@ -3,6 +3,14 @@ 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(System.getenv("WAITTIME").toLong()*2)
|
delay(20000L)
|
||||||
}
|
}
|
@ -1,3 +1,4 @@
|
|||||||
|
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