cleanup

Author: apacheborys

src/BasicTransport/FileTransport.php

@@ -72,8 +72,12 @@ public function fetchUnprocessedMessages(int $batchSize = -1): ?iterable
         $returnedItems = 0;
 
         foreach ($this->fileIndexProcessed[0] ?? [] as $position) {
-            fseek($this->fp, $position + 1);
-            $rawMessage = fgets($this->fp);
+            fseek($this->fp, $position);
+            $rawMessage = trim(fgets($this->fp));
+
+            if (strlen($rawMessage) === 0) {
+                continue;
+            }
 
             $message = Message::fromArray(json_decode($rawMessage, true,512, JSON_THROW_ON_ERROR));