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') {