tukusejssirs
tukusejssirs

Reputation: 854

Different `on('message')` callback per MQTT topic in Node.js

I use MQTT.js. Is it possible to define a different callback per topic?

For example, I subscribe to topics a, b, and c and create an on message callback per topic like so:

client.on('message', 'a', cb)
client.on('message', 'b', cb)
client.on('message', 'b', cb)

If not, how can I work this around?

Upvotes: 2

Views: 1067

Answers (1)

hardillb
hardillb

Reputation: 59618

No it is not possible.

You just need to add a if/else or switch block to your on message callback that uses the topic as the selector.

e.g.

client.on('message', function(topic, message) {
  switch(topic) {
    case 'a':
      ...
      break;
    case 'b':
      ...
      break;
    default:
      ...
  }
})

or store callback function in an object and use topics as the key e.g.

var callbacks = {}

callbacks["a"] = function(message) {...}

client.on('message', function(topic, message) {

  callbacks[topic](message)

})

Upvotes: 0

Related Questions