symfony
diff --git a/‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php
+3-1Lines changed: 3 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php
+3-1Lines changed: 3 additions & 1 deletion
@@ -60,9 +60,11 @@ private function getEnvelope(string $queueName): iterable
             return;
         }
 
+        $body = $amqpEnvelope->getBody();
+
         try {
             $envelope = $this->serializer->decode([
-                'body' => $amqpEnvelope->getBody(),
+                'body' => false === $body ? '' : $body, // workaround https://github.com/pdezwart/php-amqp/issues/351
                 'headers' => $amqpEnvelope->getHeaders(),
             ]);
         } catch (MessageDecodingFailedException $exception) {