commit b7a0ef78be614884f70c946ddd720a4ce38c6434
author Daniel Blankensteiner <db@vmail.dk> Mon Oct 21 21:13:36 2019 +0200
committer GitHub <noreply@github.com> Mon Oct 21 21:13:36 2019 +0200
tree 161d99aa864e1d9b87733d960a6601d816b577bf
parent 32faa6e2047e078dd6fc322c511b334a29de29c0
parent 0722885b973bd111a135f5f52f86a8a70d577f04

Merge pull request #9 from janpieterz/feature/default-send-increment-sequence

Set the sequence id when sending using default metadata

src/DotPulsar/Internal/ProducerStream.cs

diff --git a/src/DotPulsar/Internal/ProducerStream.cs b/src/DotPulsar/Internal/ProducerStream.cs
index 839a681..a5827ca 100644
--- a/src/DotPulsar/Internal/ProducerStream.cs
+++ b/src/DotPulsar/Internal/ProducerStream.cs
@@ -42,7 +42,11 @@
             }
         }
 
-        public async Task<CommandSendReceipt> Send(ReadOnlySequence<byte> payload) => await Send(_cachedMetadata, payload);
+        public Task<CommandSendReceipt> Send(ReadOnlySequence<byte> payload)
+        {
+            _cachedMetadata.SequenceId = _sequenceId.Current;
+            return Send(_cachedMetadata, payload);
+        }
 
         public async Task<CommandSendReceipt> Send(PulsarApi.MessageMetadata metadata, ReadOnlySequence<byte> payload)
         {