增加总线主题接收 TOPIC_CLIENT_NTF // 发给客户端的通知

global/topic.go

@@ -1,7 +1,8 @@
 package global
 
 var (
-	TOPIC_RSP_NTF = "notify_rsp" // 回报主题（通知）
+	TOPIC_RSP_NTF    = "notify_rsp" // 回报主题（通知）
+	TOPIC_CLIENT_NTF = "client_ntf" // 发给客户端的通知
 
 	TOPIC_REQ_QKERNEL = "query_req" // 查询相关请求
 	TOPIC_RSP_QKERNEL = "query_rsp" // 查询相关回应

initialize/rabbitmq.go

@@ -795,6 +795,10 @@ func RabbitMQSubscribeTopic() (err error) {
 		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