Fix PR issue

Daniil Zulin · Daniil Zulin · commit 2f92d0a34993 · 2024-09-27T16:18:25.000+07:00
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
@@ -289,9 +289,9 @@ 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);

Original file line number	Diff line number	Diff line change
`@@ -289,9 +289,9 @@ private void free(int messageCount, long sizeBytes) {`
`289`	`289`	`return;`
`290`	`290`	`}`
`291`	`291`	`logger.trace("[{}] Putting a message into send buffer after freeing some space", id);`
	`292`	`+ incomingQueue.remove();`
`292`	`293`	`if (incomingMessage.future.complete(null)) {`
`293`	`294`	`acceptMessageIntoSendingQueue(incomingMessage.message);`
`294`		`- incomingQueue.remove();`
`295`	`295`	`}`
`296`	`296`	`}`
`297`	`297`	`logger.trace("[{}] All messages from incomingQueue are accepted into send buffer", id);`