From 3d0c25febd25c5fad98a0a5f4d607d369db0ae1f Mon Sep 17 00:00:00 2001 From: echooymxq Date: Tue, 26 Aug 2025 08:58:00 +0800 Subject: [PATCH] [ISSUE #503] Fix ConsumerRunningInfo deserialize error --- src/protocol/ConsumerRunningInfo.cpp | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/src/protocol/ConsumerRunningInfo.cpp b/src/protocol/ConsumerRunningInfo.cpp index 6ef5571ed..6db875241 100644 --- a/src/protocol/ConsumerRunningInfo.cpp +++ b/src/protocol/ConsumerRunningInfo.cpp @@ -105,14 +105,16 @@ string ConsumerRunningInfo::encode() { string finals = fastwrite.write(root); string key = "\"mqTable\":"; key.append("{"); - for (map::iterator it = mqTable.begin(); it != mqTable.end(); ++it) { - key.append((it->first).toJson().toStyledString()); + if (!mqTable.empty()) { + for (map::iterator it = mqTable.begin(); it != mqTable.end(); ++it) { + key.append((it->first).toJson().toStyledString()); + key.erase(key.end() - 1); + key.append(":"); + key.append((it->second).toJson().toStyledString()); + key.append(","); + } key.erase(key.end() - 1); - key.append(":"); - key.append((it->second).toJson().toStyledString()); - key.append(","); } - key.erase(key.end() - 1); key.append("}"); // insert mqTable to final string