update

initialize/rabbitmq.go

@@ -919,14 +919,14 @@ func RabbitMQSubscribeTopic() (err error) {
 		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
 		return
 	}
-	if err = rabbitmq.SubscribeTopic(global.TOPIC_RSP_NTF); err != nil {
-		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
-		return
-	}
-	if err = rabbitmq.SubscribeTopic(global.TOPIC_CLIENT_NTF); err != nil {
-		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
-		return
-	}
+	// if err = rabbitmq.SubscribeTopic(global.TOPIC_RSP_NTF); err != nil {
+	// 	global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
+	// 	return
+	// }
+	// if err = rabbitmq.SubscribeTopic(global.TOPIC_CLIENT_NTF); err != nil {
+	// 	global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
+	// 	return
+	// }
 	if err = rabbitmq.SubscribeTopic(global.TOPIC_RSP_QKERNEL); err != nil {
 		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
 		return