Wildcard change

Author: lmn

nmqtt.nim

@@ -836,7 +836,12 @@ proc onPublish(ctx: MqttCtx, pkt: Pkt) {.async.} =
 
   when not defined(broker):
     for top, cb in ctx.pubCallbacks:
-      if top == topic or top.endsWith("#"): cb.cb(topic, message)
+      if top == topic: cb.cb(topic, message)
+      if top.endsWith("#"):
+        var topicw = top
+        topicw.removeSuffix("#")
+        if topic.contains(topicw):
+          cb.cb(topic, message)
 
   if qos == 1:
     ctx.workQueue[msgId] = Work(wk: PubWork, msgId: msgId, state: WorkNew, qos: 1, typ: PubAck)