wn/dispatcher_ng
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

4button

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-01-03 15:26:00 +01:00
parent 23fab8d33c
commit 1aadc7562e
4 changed files with 91 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/mqttHandler.js
View File

@ -27,9 +27,23 @@ function start() {
client.on('message', (topic, payload) => {
payload = payload.toString('UTF-8');
logger.info(`message received on topic ${topic}: ${payload}`);
if (topic in topicCallbacks) {
topicCallbacks[topic].forEach((cb) => { cb(topic, payload) });
}
//if (topic in topicCallbacks) {
// topicCallbacks[topic].forEach((cb) => { cb(topic, payload) });
//}
Object.keys(topicCallbacks).forEach((subscribedTopic) => {
// logger.warn(`Test: ${subscribedTopic}, ${topic}`);
// console.log(`Test: ${subscribedTopic}, ${topic}`);
if (subscribedTopic == topic) {
// logger.warn('1');
topicCallbacks[topic].forEach((cb) => { cb(topic, payload) });
} else if (subscribedTopic.endsWith('#') &&
(subscribedTopic.substring(0, subscribedTopic.length-1) ==
topic.substring(0, subscribedTopic.length-1))) {
// logger.warn('2');
// console.log('2');
topicCallbacks[subscribedTopic].forEach((cb) => { cb(topic, payload) });
}
});
});
}