From f0917ab67fd6d2e718a96b544babbfa07a3a3fb6 Mon Sep 17 00:00:00 2001 From: Alvaro Vega Date: Fri, 15 Dec 2023 12:22:32 +0100 Subject: [PATCH] remove protocol from messageHandler --- lib/commonBindings.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/commonBindings.js b/lib/commonBindings.js index b741245d5..685d26464 100644 --- a/lib/commonBindings.js +++ b/lib/commonBindings.js @@ -329,7 +329,7 @@ function multipleMeasures(apiKey, deviceId, device, messageObj) { * @param {String} topic Topic of the form: '//deviceId/attrs[/]'. * @param {Object} message message body (Object or Buffer, depending on the value). */ -function messageHandler(topic, message, protocol) { +function messageHandler(topic, message) { if (topic[0] !== '/') { topic = '/' + topic; } @@ -393,7 +393,7 @@ function messageHandler(topic, message, protocol) { */ function amqpMessageHandler(topic, message) { regenerateTransid(topic); - messageHandler(topic, message, 'AMQP'); + messageHandler(topic, message); } /**