commit 888c201c04eef70c965981fb3c46db24b2a2d776
author Dion Jansen <dionjansen@wlnss.com> Thu Oct 15 08:28:36 2020 +0200
committer GitHub <noreply@github.com> Thu Oct 15 08:28:36 2020 +0200
tree 941dbcd1737f4c2d1d8f33e2c376b9e744c4734f
parent d8299ad32229194a6d4154c15312b45b456091d6

Determine batching from metadata in ConsumerChannel based on ShouldSerializeNumMessagesInBatch (#63)

src/DotPulsar/Internal/ConsumerChannel.cs

diff --git a/src/DotPulsar/Internal/ConsumerChannel.cs b/src/DotPulsar/Internal/ConsumerChannel.cs
index a84e574..7ea2255 100644
--- a/src/DotPulsar/Internal/ConsumerChannel.cs
+++ b/src/DotPulsar/Internal/ConsumerChannel.cs
@@ -86,9 +86,9 @@
                     var metadata = messagePackage.ExtractMetadata(metadataSize);
                     var messageId = messagePackage.MessageId;
 
-                    return metadata.NumMessagesInBatch == 1
-                        ? new Message(new MessageId(messageId), redeliveryCount, metadata, null, data)
-                        : _batchHandler.Add(messageId, redeliveryCount, metadata, data);
+                    return metadata.ShouldSerializeNumMessagesInBatch()
+                        ? _batchHandler.Add(messageId, redeliveryCount, metadata, data)
+                        : new Message(new MessageId(messageId), redeliveryCount, metadata, null, data);
                 }
             }
         }