3.9.3 release

Author: Lanayx

src/Pulsar.Client/Pulsar.Client.fsproj

@@ -7,17 +7,17 @@
     <Title>Pulsar.Client</Title>
     <RootNamespace>Pulsar.Client</RootNamespace>
     <AssemblyName>Pulsar.Client</AssemblyName>
-    <Version>3.9.2</Version>
+    <Version>3.9.3</Version>
     <Company>F# community</Company>
     <Description>.NET client library for Apache Pulsar</Description>
     <RepositoryUrl>https://github.com/fsprojects/pulsar-client-dotnet</RepositoryUrl>
-    <PackageReleaseNotes>Background task for consumer disposal</PackageReleaseNotes>
+    <PackageReleaseNotes>Ordering key is now retained at redelivery</PackageReleaseNotes>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
     <PackageProjectUrl>https://github.com/fsprojects/pulsar-client-dotnet</PackageProjectUrl>
     <RepositoryType>git</RepositoryType>
     <PackageTags>pulsar</PackageTags>
     <Authors>Vladimir Shchur and contributors</Authors>
-    <PackageVersion>3.9.2</PackageVersion>
+    <PackageVersion>3.9.3</PackageVersion>
     <DebugType>portable</DebugType>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <PackageReadmeFile>README.md</PackageReadmeFile>

tests/IntegrationTests/DeadLetters.fs

@@ -438,49 +438,17 @@ let tests =
                     .EnableRetry(true)
                     .SubscribeAsync()
 
-            let! msgId = producer.SendAsync([| 0uy; 1uy; 0uy |])
-            let! (msg1 : Message<byte[]>) = consumer.ReceiveAsync()
-            do! consumer.ReconsumeLaterAsync(msg1, %(DateTime.UtcNow.AddSeconds(1.0) |> convertToMsTimestamp))
-            let! (msg2 : Message<byte[]>) = consumer.ReceiveAsync()
-
-            Expect.equal "" msgId msg1.MessageId
-            Expect.equal "" (msg1.GetValue() |> Array.toList) (msg2.GetValue() |> Array.toList)
-
-            description |> logTestEnd
-        }
-        
-        
-        testTask "Reconsume later retains ordering key" {
-
-            let description = "Reconsume later retains ordering key"
-
-            description |> logTestStart
-
-            let config = getTestConfig()
-            let producerName = "reconsumeProducer"
-            let consumerName = "reconsumeConsumer"
-
-            let! (producer : IProducer<byte[]>) =
-                createProducer()
-                    .ProducerName(producerName)
-                    .Topic(config.TopicName)
-                    .EnableBatching(false)
-                    .CreateAsync()
-
-            let! (consumer : IConsumer<byte[]>) =
-                createConsumer()
-                    .ConsumerName(consumerName)
-                    .Topic(config.TopicName)
-                    .SubscriptionName(config.SubscriptionName)
-                    .EnableRetry(true)
-                    .SubscribeAsync()
-
+            let data = [| 0uy; 1uy; 0uy |]
             let orderingKey = [| 1uy; 0uy; 1uy |]
-            let! _ = producer.NewMessage([| 0uy; 1uy; 0uy |], orderingKey = orderingKey) |> producer.SendAsync
+            let message = producer.NewMessage(data, orderingKey = orderingKey)
+            let! msgId = producer.SendAsync message
             let! (msg1 : Message<byte[]>) = consumer.ReceiveAsync()
             do! consumer.ReconsumeLaterAsync(msg1, %(DateTime.UtcNow.AddSeconds(1.0) |> convertToMsTimestamp))
             let! (msg2 : Message<byte[]>) = consumer.ReceiveAsync()
 
+            Expect.equal "" msgId msg1.MessageId
+            Expect.equal "" data (msg1.GetValue())
+            Expect.equal "" data (msg2.GetValue())
             Expect.equal "" orderingKey msg1.OrderingKey
             Expect.equal "" orderingKey msg2.OrderingKey