[Messenger] Add forward compatibily with php-amqp v2

lyrixx · lyrixx · commit 9d69dd6d9275 · 2023-07-30T12:44:59.000+02:00
see php-amqp/php-amqp#424 (comment)
diff --git a/Transport/Connection.php b/Transport/Connection.php
@@ -456,7 +456,7 @@ public function get(string $queueName): ?\AMQPEnvelope
 
     public function ack(\AMQPEnvelope $message, string $queueName): bool
     {
-        return $this->queue($queueName)->ack($message->getDeliveryTag());
+        return $this->queue($queueName)->ack($message->getDeliveryTag()) ?? true;
     }
 
     public function nack(\AMQPEnvelope $message, string $queueName, int $flags = \AMQP_NOPARAM): bool

Original file line number	Diff line number	Diff line change
`@@ -456,7 +456,7 @@ public function get(string $queueName): ?\AMQPEnvelope`
`456`	`456`
`457`	`457`	`public function ack(\AMQPEnvelope $message, string $queueName): bool`
`458`	`458`	`{`
`459`		`- return $this->queue($queueName)->ack($message->getDeliveryTag());`
	`459`	`+ return $this->queue($queueName)->ack($message->getDeliveryTag()) ?? true;`
`460`	`460`	`}`
`461`	`461`
`462`	`462`	`public function nack(\AMQPEnvelope $message, string $queueName, int $flags = \AMQP_NOPARAM): bool`