forked from xHasKx/luamqtt
-
Notifications
You must be signed in to change notification settings - Fork 0
/
simple.lua
53 lines (44 loc) · 1.37 KB
/
simple.lua
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
-- load mqtt module
local mqtt = require("mqtt")
-- create mqtt client
local client = mqtt.client{
-- NOTE: this broker is not working sometimes; comment username = "..." below if you still want to use it
-- uri = "test.mosquitto.org",
uri = "mqtt.flespi.io",
-- NOTE: more about flespi tokens: https://flespi.com/kb/tokens-access-keys-to-flespi-platform
username = "stPwSVV73Eqw5LSv0iMXbc4EguS7JyuZR9lxU5uLxI5tiNM8ToTVqNpu85pFtJv9",
clean = true,
}
print("created MQTT client", client)
client:on{
connect = function(connack)
if connack.rc ~= 0 then
print("connection to broker failed:", connack:reason_string(), connack)
return
end
print("connected:", connack) -- successful connection
-- subscribe to test topic and publish message after it
assert(client:subscribe{ topic="luamqtt/#", qos=1, callback=function(suback)
print("subscribed:", suback)
-- publish test message
print('publishing test message "hello" to "luamqtt/simpletest" topic...')
assert(client:publish{
topic = "luamqtt/simpletest",
payload = "hello",
qos = 1
})
end})
end,
message = function(msg)
assert(client:acknowledge(msg))
print("received:", msg)
print("disconnecting...")
assert(client:disconnect())
end,
error = function(err)
print("MQTT client error:", err)
end,
}
print("running ioloop for it")
mqtt.run_ioloop(client)
print("done, ioloop is stopped")