Only subscribe to each topic once
This commit is contained in:
parent
3c96bde015
commit
fda6a95359
2 changed files with 4 additions and 2 deletions
|
|
@ -5,7 +5,8 @@ const config : Config = {
|
||||||
space: {
|
space: {
|
||||||
name: "RZL",
|
name: "RZL",
|
||||||
color: "orange",
|
color: "orange",
|
||||||
mqtt: "ws://map.rzl:1884"
|
mqtt: "ws://192.168.178.90:1884"
|
||||||
|
//mqtt: "ws://map.rzl:1884"
|
||||||
},
|
},
|
||||||
topics: [
|
topics: [
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,6 @@
|
||||||
// @flow
|
// @flow
|
||||||
import mqtt from "mqtt";
|
import mqtt from "mqtt";
|
||||||
|
import _ from "lodash";
|
||||||
|
|
||||||
// TODO: type mqtt.js
|
// TODO: type mqtt.js
|
||||||
|
|
||||||
|
|
@ -21,7 +22,7 @@ export default function connectMqtt(
|
||||||
const client = mqtt.connect(url);
|
const client = mqtt.connect(url);
|
||||||
client.on("connect", () => {
|
client.on("connect", () => {
|
||||||
if (settings.subscribe != null) {
|
if (settings.subscribe != null) {
|
||||||
client.subscribe(settings.subscribe);
|
client.subscribe(_.uniq(settings.subscribe));
|
||||||
}
|
}
|
||||||
if (settings.onConnect != null) {
|
if (settings.onConnect != null) {
|
||||||
settings.onConnect(client);
|
settings.onConnect(client);
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue