From 3b9cbe5ef247d725baaef47ae694815c111a6ee5 Mon Sep 17 00:00:00 2001 From: Torma Date: Wed, 21 Oct 2020 02:20:38 +0200 Subject: [PATCH] test mqtt --- src/Application.kt | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/Application.kt b/src/Application.kt index 61d7595..f90590e 100644 --- a/src/Application.kt +++ b/src/Application.kt @@ -36,6 +36,7 @@ fun Application.module(testing: Boolean = false) { connOpts.password = appConfig.property("ktor.mq.password").getString().toCharArray() mqttClient.connect(connOpts) message.qos = 0 + mqttClient.publish("benchmark/startup", message) } environment.monitor.subscribe(ApplicationStopped){ @@ -52,6 +53,7 @@ fun Application.module(testing: Boolean = false) { when (part) { is PartData.FormItem -> { if (part.name == "description") { + println("Sending MQTT Message") val msgObj: MessageObject = gson.fromJson(part.value,MessageObject::class.java) mqttClient.publish("command/${msgObj.device_id}", message) }