删除消息队列的停止逻辑

framework/core/infrastructure/message_queue/redis/redis.go

@@ -88,11 +88,6 @@ func Destroy(messageQueue *MessageQueue) {
 	messageQueue.consumerMapMutex.Lock()
 	defer messageQueue.consumerMapMutex.Unlock()
 
-	for _, consumer := range messageQueue.consumerMap {
-		consumer.Shutdown()
-		consumer = nil
-	}
-
 	messageQueue.consumerMap = nil
 }
 
@@ -151,13 +146,6 @@ func (messageQueue *MessageQueue) UnSubscribe(group string, topic string) error
 	defer messageQueue.consumerMapMutex.Unlock()
 
 	groupTopic := messageQueue.formGroupTopic(group, topic)
-
-	consumer, ok := messageQueue.consumerMap[groupTopic]
-	if !ok {
-		return nil
-	}
-
-	consumer.Shutdown()
 	delete(messageQueue.consumerMap, groupTopic)
 
 	return nil