From 330545ad38bc54b172439105c92c9b848e4e4c91 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Aleksandar=20Novakovi=C4=87?= <anovakovic01@gmail.com>
Date: Mon, 28 Jan 2019 22:55:14 +0100
Subject: [PATCH] Fix MQTT adapter by setting subscription queue (#561)

Signed-off-by: Aleksandar Novakovic <aleksandar.novakovic@mainflux.com>
---
 mqtt/mqtt.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/mqtt/mqtt.js b/mqtt/mqtt.js
index 91d27037..839d3d32 100644
--- a/mqtt/mqtt.js
+++ b/mqtt/mqtt.js
@@ -80,7 +80,7 @@ function startMqtt() {
     return net.createServer(aedes.handle).listen(config.mqtt_port);
 }
 
-nats.subscribe('channel.*', function (msg) {
+nats.subscribe('channel.*', {'queue':'mqtts'}, function (msg) {
     var m = message.RawMessage.decode(Buffer.from(msg)),
         packet;
     if (m && m.Protocol !== 'mqtt') {