mgillespie/TinyMqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added unsubscribe to tinytest

Browse Source
This commit is contained in:
hsaturn
2021-04-10 17:14:57 +02:00
parent 8a25155fd8
commit 838df3a34a
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
examples/tinymqtt-test/tinymqtt-test.ino
View File

@@ -129,7 +129,7 @@ std::set<std::string> commands = {
"auto", "broker", "blink", "client", "connect", "auto", "broker", "blink", "client", "connect",
"create", "delete", "help", "interval", "create", "delete", "help", "interval",
"ls", "ip", "off", "on", "set", "ls", "ip", "off", "on", "set",
"publish", "reset", "subscribe", "view" "publish", "reset", "subscribe", "unsubscribe", "view"
}; };
void getCommand(std::string& search) void getCommand(std::string& search)
@@ -481,6 +481,10 @@ void loop()
{ {
client->subscribe(getword(cmd, topic.c_str())); client->subscribe(getword(cmd, topic.c_str()));
} }
else if (compare(s, "unsubscribe"))
{
client->unsubscribe(getword(cmd, topic.c_str()));
}
else if (compare(s, "view")) else if (compare(s, "view"))
{ {
client->dump(); client->dump();
@@ -611,7 +615,7 @@ void loop()
Serial << " MqttClient:" << endl; Serial << " MqttClient:" << endl;
Serial << " client {name} {parent broker} : create a client then" << endl; Serial << " client {name} {parent broker} : create a client then" << endl;
Serial << " name.connect [ip] [port] [alive]" << endl; Serial << " name.connect [ip] [port] [alive]" << endl;
Serial << " name.subscribe [topic]" << endl; Serial << " name.[un]subscribe [topic]" << endl;
Serial << " name.publish [topic][payload]" << endl; Serial << " name.publish [topic][payload]" << endl;
Serial << " name.view" << endl; Serial << " name.view" << endl;
Serial << " name.delete" << endl; Serial << " name.delete" << endl;