Resolve the bug without encode batch flag when send batch message #152
Resolve the bug without encode batch flag when send batch message
diff --git a/src/protocol/CommandHeader.cpp b/src/protocol/CommandHeader.cpp
index 4e4b0bb..95ef166 100644
--- a/src/protocol/CommandHeader.cpp
+++ b/src/protocol/CommandHeader.cpp
@@ -73,7 +73,7 @@
outData["properties"] = properties;
outData["reconsumeTimes"] = UtilAll::to_string(reconsumeTimes);
outData["unitMode"] = UtilAll::to_string(unitMode);
- // outData["batch"] = batch;
+ outData["batch"] = UtilAll::to_string(batch);
}
int SendMessageRequestHeader::getReconsumeTimes() {
@@ -106,7 +106,7 @@
requestMap.insert(pair<string, string>("properties", properties));
requestMap.insert(pair<string, string>("reconsumeTimes", UtilAll::to_string(reconsumeTimes)));
requestMap.insert(pair<string, string>("unitMode", UtilAll::to_string(unitMode)));
- // requestMap.insert(pair<string, string>("batch", UtilAll::to_string(batch)));
+ requestMap.insert(pair<string, string>("batch", UtilAll::to_string(batch)));
}
//<!************************************************************************
