|
|
@@ -146,12 +146,6 @@ func (messageQueue *MessageQueue) UnSubscribe(group string, topic string) error
|
|
|
defer messageQueue.consumerMapMutex.Unlock()
|
|
|
|
|
|
groupTopic := messageQueue.formGroupTopic(group, topic)
|
|
|
-
|
|
|
- _, ok := messageQueue.consumerMap[groupTopic]
|
|
|
- if !ok {
|
|
|
- return nil
|
|
|
- }
|
|
|
-
|
|
|
delete(messageQueue.consumerMap, groupTopic)
|
|
|
|
|
|
return nil
|