1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 import asyncdispatch, options
import types, vars
import nmqtt
proc initMqtt* () {.async.} =
try:
var config = server.config.serverConfig.mqtt.get
mqttContext = newMqttCtx("smartied")
mqttContext.set_host(config.host, config.port)
await mqttContext.start()
except:
echo "Error[initMqtt]:\n", getCurrentExceptionMsg()
quit()