Added additional check for empty string or inability to deserialize i…

…ncoming message
goodway · Apr 26, 2024 · ee01e90 · ee01e90
1 parent 98504ab
commit ee01e90
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/DTO/NatsMessage.php b/src/DTO/NatsMessage.php
@@ -95,7 +95,7 @@ public function toArray(): array
     public static function parse(array|object|string $payload, bool $deserialize = false): NatsMessage
     {
         if (is_string($payload)) {
-            if (!$deserialize) {
+            if (!$deserialize || empty($payload)) {
                 return new self ($payload);
             }
             $payload = unserialize($payload);

diff --git a/src/Queue/Handlers/NatsQueueHandler.php b/src/Queue/Handlers/NatsQueueHandler.php
@@ -93,7 +93,7 @@ public function pop(): void
             ->handle(
                 function ($message) use ($consumer) {
 
-                    $messageData = unserialize($message);
+                    $messageData = unserialize($message) ?: '';
                     $messageObj = NatsMessage::parse($messageData, true);
 
                     if ($this->fireEvent) {