Skip to content

Commit

Permalink
remove protocol from messageHandler
Browse files Browse the repository at this point in the history
  • Loading branch information
AlvaroVega committed Dec 15, 2023
1 parent ace7653 commit f0917ab
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/commonBindings.js
Original file line number Diff line number Diff line change
Expand Up @@ -329,7 +329,7 @@ function multipleMeasures(apiKey, deviceId, device, messageObj) {
* @param {String} topic Topic of the form: '/<APIKey>/deviceId/attrs[/<attributeName>]'.
* @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;
}
Expand Down Expand Up @@ -393,7 +393,7 @@ function messageHandler(topic, message, protocol) {
*/
function amqpMessageHandler(topic, message) {
regenerateTransid(topic);
messageHandler(topic, message, 'AMQP');
messageHandler(topic, message);
}

/**
Expand Down

0 comments on commit f0917ab

Please sign in to comment.