Merge pull request #321 from Eistern/bugfix/update-writer-for-direct-…

…executor

Remove incomingMessage from the incomingQueue only once

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);
             }