C++ Client - fix for seeing correct msg rate in broker stats (apache#462

)
afalko · Jun 9, 2017 · 0ddb5fe · 0ddb5fe
1 parent 0d0c9ed
commit 0ddb5fe
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar-client-cpp/lib/Commands.cc b/pulsar-client-cpp/lib/Commands.cc
@@ -76,6 +76,9 @@ PairSharedBuffer Commands::newSend(SharedBuffer& headers, BaseCommand& cmd,
     CommandSend* send = cmd.mutable_send();
     send->set_producer_id(producerId);
     send->set_sequence_id(sequenceId);
+    if (metadata.has_num_messages_in_batch()) {
+        send->set_num_messages(metadata.num_messages_in_batch());
+    }
 
     // / Wire format
     // [TOTAL_SIZE] [CMD_SIZE][CMD] [MAGIC_NUMBER][CHECKSUM] [METADATA_SIZE][METADATA] [PAYLOAD]