diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceiverTest.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceiverTest.php
index b0e27690b5030..4065d6f505b12 100644
--- a/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpReceiverTest.php
+++ b/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;
         });
     }
 
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php
index 1f888a84c04f0..a1fb5421e84a6 100644
--- a/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpTransportTest.php
+++ b/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;
         });
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php
index e7318f722ba59..15092b0c3f694 100644
--- a/src/Symfony/Component/Messenger/Bridge/Amqp/Transport/Connection.php
+++ b/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
      */
diff --git a/src/Symfony/Component/Messenger/Transport/Receiver/BlockingReceiverInterface.php b/src/Symfony/Component/Messenger/Transport/Receiver/BlockingReceiverInterface.php
index 8e49a50402a21..4f4999b7b396d 100644
--- a/src/Symfony/Component/Messenger/Transport/Receiver/BlockingReceiverInterface.php
+++ b/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
diff --git a/src/Symfony/Component/Messenger/Transport/Receiver/QueueBlockingReceiverInterface.php b/src/Symfony/Component/Messenger/Transport/Receiver/QueueBlockingReceiverInterface.php
index 4284f03250b1e..8cff47c67838e 100644
--- a/src/Symfony/Component/Messenger/Transport/Receiver/QueueBlockingReceiverInterface.php
+++ b/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;
diff --git a/src/Symfony/Component/Messenger/Worker.php b/src/Symfony/Component/Messenger/Worker.php
index 90e3604ad69e7..9f3bc6282a7a2 100644
--- a/src/Symfony/Component/Messenger/Worker.php
+++ b/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);