[pulsar-dotpulsar] branch master updated: Determine batching from metadata in ConsumerChannel based on ShouldSerializeNumMessagesInBatch (#63)

[blankensteiner]

This is an automated email from the ASF dual-hosted git repository.

blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 888c201  Determine batching from metadata in ConsumerChannel based on 
ShouldSerializeNumMessagesInBatch (#63)
888c201 is described below

commit 888c201c04eef70c965981fb3c46db24b2a2d776
Author: Dion Jansen <dionjan...@wlnss.com>
AuthorDate: Thu Oct 15 08:28:36 2020 +0200

    Determine batching from metadata in ConsumerChannel based on 
ShouldSerializeNumMessagesInBatch (#63)
---
 src/DotPulsar/Internal/ConsumerChannel.cs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 @@ namespace DotPulsar.Internal
                     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);
                 }
             }
         }