ARCH-414 No need for the callback to have a nullable return param

src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceiverTest.php

@@ -67,9 +67,9 @@ public function testItReturnsTheDecodedMessageToTheHandlerInBlockingMode()
         });
 
         $receiver = new AmqpReceiver($connection, $serializer);
-        $receiver->pull(function (Envelope $envelope): ?bool {
+        $receiver->pull(function (Envelope $envelope): bool {
             $this->assertEquals(new DummyMessage('Hi'), $envelope->getMessage());
-            return null;
+            return true;
         });
     }
 

src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php

@@ -77,7 +77,7 @@ public function testReceivesMessagesInBlockingMode()
             \call_user_func($callback, $amqpEnvelope, $amqpQueue);
         });
 
-        $transport->pull(function (Envelope $envelope) use ($decodedMessage): ?bool {
+        $transport->pull(function (Envelope $envelope) use ($decodedMessage): bool {
             $this->assertSame($decodedMessage, $envelope->getMessage());
             return null;
         });

src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php

@@ -468,10 +468,10 @@ public function get(string $queueName): ?\AMQPEnvelope
     /**
      * Consume a message from the specified queue in blocking mode.
      *
-     * @param ?callable(\AMQPEnvelope,\AMQPQueue):?bool $callback If callback return false, then processing thread will be
-     *                                                            returned from AMQPQueue::consume() to PHP script. If null is passed, then the messages delivered to this client
-     *                                                            will be made available to the first real callback registered. That allows one to have a single callback
-     *                                                            consuming from multiple queues.
+     * @param ?callable(\AMQPEnvelope,\AMQPQueue):bool $callback If callback return false, then processing thread will be
+     *                                                           returned from AMQPQueue::consume() to PHP script. If null is passed, then the messages delivered to this client
+     *                                                           will be made available to the first real callback registered. That allows one to have a single callback
+     *                                                           consuming from multiple queues.
      *
      * @throws \AMQPException
      */

src/Symfony/Component/Messenger/Transport/Receiver/BlockingReceiverInterface.php

@@ -19,7 +19,7 @@
 interface BlockingReceiverInterface extends ReceiverInterface
 {
     /**
-     * @param callable(\AMQPEnvelope):?bool $callback If callback return false, then processing thread will be
+     * @param callable(\AMQPEnvelope):bool $callback If callback return false, then processing thread will be
      * returned to PHP script.
      *
      * @throws TransportException If there is an issue communicating with the transport

src/Symfony/Component/Messenger/Transport/Receiver/QueueBlockingReceiverInterface.php

@@ -22,7 +22,7 @@ interface QueueBlockingReceiverInterface extends BlockingReceiverInterface
      * Pull messages from the specified queue names instead of consuming from all queues.
      *
      * @param string[] $queueNames
-     * @param callable(\AMQPEnvelope):?bool $callback If callback return false, then processing thread will be
+     * @param callable(\AMQPEnvelope):bool $callback If callback return false, then processing thread will be
      * returned to PHP script.
      */
     public function pullFromQueues(array $queueNames, callable $callback): void;

src/Symfony/Component/Messenger/Worker.php

@@ -115,7 +115,7 @@ public function run(array $options = []): void
             $envelopeHandledStart = $this->clock->now();
             foreach ($this->receivers as $transportName => $receiver) {
                 if ($blockingMode) {
-                    $callback = function (Envelope $envelope) use ($transportName, &$envelopeHandled): ?bool {
+                    $callback = function (Envelope $envelope) use ($transportName, &$envelopeHandled): bool {
                         $envelopeHandled = true;
                         $this->handleMessage($envelope, $transportName);