diff --git a/mqtt/mqtt.js b/mqtt/mqtt.js index 27bfd594..91d27037 100644 --- a/mqtt/mqtt.js +++ b/mqtt/mqtt.js @@ -149,7 +149,7 @@ aedes.authorizePublish = function (client, packet, publish) { aedes.authorizeSubscribe = function (client, packet, subscribe) { // Topics are in the form `channels//messages` // Subtopic's are in the form `channels//messages/` - var channel = /^channels\/(.+?)\/messages\/?(.+?)?$/.exec(packet.topic); + var channel = /^channels\/(.+?)\/messages\/?.*$/.exec(packet.topic); if (!channel) { logger.warn('unknown topic'); subscribe(4, packet); // Bad username or password