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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
#!/usr/bin/lua
--
-- mqtt_subscribe.lua
-- ~~~~~~~~~~~~~~~~~~
-- Version: 0.2 2012-06-01
-- ------------------------------------------------------------------------- --
-- Copyright (c) 2011-2012 Geekscape Pty. Ltd.
-- All rights reserved. This program and the accompanying materials
-- are made available under the terms of the Eclipse Public License v1.0
-- which accompanies this distribution, and is available at
-- http://www.eclipse.org/legal/epl-v10.html
--
-- Contributors:
-- Andy Gelme - Initial implementation
-- -------------------------------------------------------------------------- --
--
-- Description
-- ~~~~~~~~~~~
-- Subscribe to an MQTT topic and display any received messages.
--
-- References
-- ~~~~~~~~~~
-- Lapp Framework: Lua command line parsing
-- http://lua-users.org/wiki/LappFramework
--
-- ToDo
-- ~~~~
-- None, yet.
-- ------------------------------------------------------------------------- --
function callback(
topic, -- string
message) -- string
print("Topic: " .. topic .. ", message: '" .. message .. "'")
end
-- ------------------------------------------------------------------------- --
function is_openwrt()
return(os.getenv("USER") == "root") -- Assume logged in as "root" on OpenWRT
end
-- ------------------------------------------------------------------------- --
print("[mqtt_subscribe v0.2 2012-06-01]")
if (not is_openwrt()) then require("luarocks.require") end
local lapp = require("pl.lapp")
local args = lapp [[
Subscribe to a specified MQTT topic
-d,--debug Verbose console logging
-H,--host (default localhost) MQTT server hostname
-i,--id (default mqtt_sub) MQTT client identifier
-k,--keepalive (default 60) Send MQTT PING period (seconds)
-p,--port (default 1883) MQTT server port number
-t,--topic (string) Subscription topic
-w,--will_message (default .) Last will and testament message
-w,--will_qos (default 0) Last will and testament QOS
-w,--will_retain (default 0) Last will and testament retention
-w,--will_topic (default .) Last will and testament topic
]]
local MQTT = require "paho.mqtt"
if (args.debug) then MQTT.Utility.set_debug(true) end
if (args.keepalive) then MQTT.client.KEEP_ALIVE_TIME = args.keepalive end
local mqtt_client = MQTT.client.create(args.host, args.port, callback)
if (args.will_message == "." or args.will_topic == ".") then
mqtt_client:connect(args.id)
else
mqtt_client:connect(
args.id, args.will_topic, args.will_qos, args.will_retain, args.will_message
)
end
mqtt_client:subscribe({args.topic})
local error_message = nil
while (error_message == nil) do
error_message = mqtt_client:handler()
socket.sleep(1.0) -- seconds
end
if (error_message == nil) then
mqtt_client:unsubscribe({args.topic})
mqtt_client:destroy()
else
print(error_message)
end
-- ------------------------------------------------------------------------- --
|
