From ee5cbe365888898fc18a1a282c32c7428cea6d65 Mon Sep 17 00:00:00 2001 From: Tobias Schultze Date: Thu, 5 Sep 2019 18:44:17 +0200 Subject: [PATCH] [Messenger] fix empty amqp body returned as false --- .../Component/Messenger/Transport/AmqpExt/AmqpReceiver.php | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php b/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php index 3c0f48eaa2..73bd083178 100644 --- a/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php +++ b/src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php @@ -60,9 +60,11 @@ class AmqpReceiver implements ReceiverInterface, MessageCountAwareInterface 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) {