We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 12a73b1 commit b566decCopy full SHA for b566dec
src/MQClientFactory.cpp
@@ -232,8 +232,8 @@ boost::shared_ptr<TopicPublishInfo> MQClientFactory::topicRouteData2TopicPublish
232
for (size_t i = 0; i < brokers.size(); i++) {
233
vector<string> item;
234
UtilAll::Split(item, brokers[i], ':');
235
- int nums = atoi(item[1].c_str());
236
- for (int i = 0; i < nums; i++) {
+ size_t nums = (item.size() > 1) ? atoi(item[1].c_str()) : 0;
+ for (size_t i = 0; i < nums; i++) {
237
MQMessageQueue mq(topic, item[0], i);
238
info->updateMessageQueueList(mq);
239
}
0 commit comments