From 016caeb07cae0652360c3d79a6b25357a0ed4bc0 Mon Sep 17 00:00:00 2001
From: lnk <yuzhiboyoulunankun@qq.com>
Date: Tue, 16 Sep 2025 11:15:04 +0800
Subject: [PATCH] use tag

---
 LFtid1056/cloudfront/code/main.cpp | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/LFtid1056/cloudfront/code/main.cpp b/LFtid1056/cloudfront/code/main.cpp
index ad32671..82e5422 100644
--- a/LFtid1056/cloudfront/code/main.cpp
+++ b/LFtid1056/cloudfront/code/main.cpp
@@ -401,14 +401,14 @@ void Front::mqconsumerThread()
         std::vector<rocketmq::Subscription> subscriptions;
 
         //if (g_node_id == THREE_SECS_DATA_BASE_NODE_ID) {
-        subscriptions.emplace_back(FRONT_INST + "_" + G_MQCONSUMER_TOPIC_RT, G_MQCONSUMER_TAG_RT, myMessageCallbackrtdata);
+        subscriptions.emplace_back(G_MQCONSUMER_TOPIC_RT, FRONT_INST, myMessageCallbackrtdata);
         //}
-        subscriptions.emplace_back(FRONT_INST + "_" + G_MQCONSUMER_TOPIC_UD, G_MQCONSUMER_TAG_UD, myMessageCallbackupdate);
+        subscriptions.emplace_back(G_MQCONSUMER_TOPIC_UD, FRONT_INST, myMessageCallbackupdate);
         //if (g_node_id == RECALL_HIS_DATA_BASE_NODE_ID) {
-        subscriptions.emplace_back(FRONT_INST + "_" + G_MQCONSUMER_TOPIC_RC, G_MQCONSUMER_TAG_RC, myMessageCallbackrecall);
+        subscriptions.emplace_back(G_MQCONSUMER_TOPIC_RC, FRONT_INST, myMessageCallbackrecall);
         //}
-        subscriptions.emplace_back(FRONT_INST + "_" + G_MQCONSUMER_TOPIC_SET, G_MQCONSUMER_TAG_SET, myMessageCallbackset);
-        subscriptions.emplace_back(FRONT_INST + "_" + G_MQCONSUMER_TOPIC_LOG, G_MQCONSUMER_TAG_LOG, myMessageCallbacklog);
+        subscriptions.emplace_back(G_MQCONSUMER_TOPIC_SET, FRONT_INST, myMessageCallbackset);
+        subscriptions.emplace_back(G_MQCONSUMER_TOPIC_LOG, FRONT_INST, myMessageCallbacklog);
 
         m_mqConsumer = make_unique<rocketmq::DefaultMQPushConsumer>(consumerGroup);
         m_mqConsumer->setNamesrvAddr(nameServer);