From cc997db5a205f54552cb3c86cee7608c642577b1 Mon Sep 17 00:00:00 2001
From: Vladimir Shchur <odindafna2006@rambler.ru>
Date: Thu, 21 Nov 2024 08:51:54 -0800
Subject: [PATCH] Fixed message dequeue in RecoverNotAllowedError error handlng

---
 src/Pulsar.Client/Internal/ProducerImpl.fs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/Pulsar.Client/Internal/ProducerImpl.fs b/src/Pulsar.Client/Internal/ProducerImpl.fs
index 9c746741..21571d86 100644
--- 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
                         )