Fixed message dequeue in RecoverNotAllowedError error handlng

fsprojects · Nov 21, 2024 · cc997db · cc997db
1 parent 93bd8f6
commit cc997db
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/Pulsar.Client/Internal/ProducerImpl.fs b/src/Pulsar.Client/Internal/ProducerImpl.fs
@@ -708,6 +708,7 @@ type internal ProducerImpl<'T> private (producerConfig: ProducerConfiguration, c
                     let pendingMessage = pendingMessages.Peek()
                     let expectedSequenceId = getHighestSequenceId pendingMessage
                     if sequenceId = expectedSequenceId then
+                        dequeuePendingMessage pendingMessage
                         failPendingMessage pendingMessage (
                             prefix + ": the size of the message is not allowed" |> NotAllowedException
                         )