Merge pull request #3 from apacheborys/bug/fix-bugs

Bug/fix bugs

Author: apacheborys

composer.json

@@ -11,7 +11,7 @@
     ],
     "require": {
         "php": "^7.4||^8.0",
-        "apacheborys/re-try-php": "*",
+        "apacheborys/re-try-php": "^0.14",
         "psr/log": "^1.1"
     },
     "require-dev": {

composer.lock

@@ -1,7 +1,8 @@
 FROM php:7.4-cli
 RUN apt-get update && apt-get install -y \
-	&& apt-get install git unzip wget curl -y \
+	&& apt-get install git unzip wget curl libsodium-dev -y \
     && pecl install inotify mongodb \
+    && docker-php-ext-install sodium \
     && echo "extension=mongodb.so" >> /usr/local/etc/php/php.ini \
     && echo "extension=inotify.so" >> /usr/local/etc/php/php.ini \
 	&& curl -sS https://getcomposer.org/installer |php \

docker-image/Dockerfile

@@ -71,7 +71,7 @@ public function fetchUnprocessedMessages(int $batchSize = -1): ?iterable
 
         $returnedItems = 0;
 
-        foreach ($this->fileIndexProcessed[0] as $position) {
+        foreach ($this->fileIndexProcessed[0] ?? [] as $position) {
             fseek($this->fp, $position + 1);
             $rawMessage = fgets($this->fp);