diff --git a/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php b/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php index 3c0f48eaa28d..73bd083178dc 100644 --- a/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php +++ b/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php @@ -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) {