(fix): wrap topic with namespace when unsubscribe (apache#680)

superhx · web-flow · commit de657f5ff1bf · 2021-06-17T14:03:14.000+08:00
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -250,6 +250,9 @@ func (pc *pushConsumer) Subscribe(topic string, selector MessageSelector,
 }
 
 func (pc *pushConsumer) Unsubscribe(topic string) error {
+	if pc.option.Namespace != "" {
+		topic = pc.option.Namespace + "%" + topic
+	}
 	pc.subscriptionDataTable.Delete(topic)
 	retryTopic := internal.GetRetryTopic(pc.consumerGroup)
 	pc.subscriptionDataTable.Delete(retryTopic)

Original file line number	Diff line number	Diff line change
`@@ -250,6 +250,9 @@ func (pc *pushConsumer) Subscribe(topic string, selector MessageSelector,`
`250`	`250`	`}`
`251`	`251`
`252`	`252`	`func (pc *pushConsumer) Unsubscribe(topic string) error {`
	`253`	`+ if pc.option.Namespace != "" {`
	`254`	`+ topic = pc.option.Namespace + "%" + topic`
	`255`	`+ }`
`253`	`256`	`pc.subscriptionDataTable.Delete(topic)`
`254`	`257`	`retryTopic := internal.GetRetryTopic(pc.consumerGroup)`
`255`	`258`	`pc.subscriptionDataTable.Delete(retryTopic)`