Merge pull request #286 from elvizlai/master

support: $queue/<topic> for sharing subscribe
eclipse · Aug 29, 2019 · 2e9e43b · 2e9e43b
2 parents 0cff61e + b271d90
commit 2e9e43b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/client.go b/client.go
@@ -670,10 +670,14 @@ func (c *client) Subscribe(topic string, qos byte, callback MessageHandler) Toke
 	sub.Qoss = append(sub.Qoss, qos)
 	DEBUG.Println(CLI, sub.String())
 
-	if strings.HasPrefix(topic, "$share") {
+	if strings.HasPrefix(topic, "$share/") {
 		topic = strings.Join(strings.Split(topic, "/")[2:], "/")
 	}
 
+	if strings.HasPrefix(topic, "$queue/") {
+		topic = strings.TrimPrefix(topic, "$queue/")
+	}
+
 	if callback != nil {
 		c.msgRouter.addRoute(topic, callback)
 	}