diff --git a/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java b/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java
index 1c01d0f8d..9674de499 100644
--- a/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java
+++ b/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java
@@ -289,10 +289,10 @@ private void free(int messageCount, long sizeBytes) {
                         return;
                     }
                     logger.trace("[{}] Putting a message into send buffer after freeing some space", id);
+                    incomingQueue.remove();
                     if (incomingMessage.future.complete(null)) {
                         acceptMessageIntoSendingQueue(incomingMessage.message);
                     }
-                    incomingQueue.remove();
                 }
                 logger.trace("[{}] All messages from incomingQueue are accepted into send buffer", id);
             }