Remove incomingMessage from the incomingQueue ony once

Daniil Zulin · Daniil Zulin · commit 8c05e0e7d6dd · 2024-09-27T00:42:13.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
@@ -291,8 +291,8 @@ private void free(int messageCount, long sizeBytes) {
                     logger.trace("[{}] Putting a message into send buffer after freeing some space", id);
                     if (incomingMessage.future.complete(null)) {
                         acceptMessageIntoSendingQueue(incomingMessage.message);
+                        incomingQueue.remove();
                     }
-                    incomingQueue.remove();
                 }
                 logger.trace("[{}] All messages from incomingQueue are accepted into send buffer", id);
             }

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