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) }