Skip to content

Commit 7eef639

Browse files
committed
fixed uniqMsgId for batch result.
1 parent 8c6f24d commit 7eef639

1 file changed

Lines changed: 5 additions & 6 deletions

File tree

src/MQClientAPIImpl.cpp

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -219,14 +219,13 @@ SendResult* MQClientAPIImpl::processSendResponse(const std::string& brokerName,
219219
if (msg->isBatch()) {
220220
const auto& messages = static_cast<const MessageBatch*>(msg)->getMessages();
221221
uniqMsgId.clear();
222-
uniqMsgId.reserve(33 * messages.size());
223-
bool isFirst = true;
222+
uniqMsgId.reserve(33 * messages.size() + 1);
224223
for (const auto& message : messages) {
225-
if (!isFirst) {
226-
uniqMsgId.append(",");
227-
isFirst = false;
228-
}
229224
uniqMsgId.append(MessageClientIDSetter::getUniqID(*message));
225+
uniqMsgId.append(",");
226+
}
227+
if (!uniqMsgId.empty()) {
228+
uniqMsgId.resize(uniqMsgId.length() - 1);
230229
}
231230
}
232231

0 commit comments

Comments
 (0)