symfony
diff --git a/‎src/Symfony/Component/Messenger/DataCollector/MessengerDataCollector.php
Lines changed: 10 additions & 1 deletion b/‎src/Symfony/Component/Messenger/DataCollector/MessengerDataCollector.php
Lines changed: 10 additions & 1 deletion
diff --git a/‎src/Symfony/Component/Messenger/Tests/DataCollector/MessengerDataCollectorTest.php
Lines changed: 2 additions & 4 deletions b/‎src/Symfony/Component/Messenger/Tests/DataCollector/MessengerDataCollectorTest.php
Lines changed: 2 additions & 4 deletions
@@ -14,14 +14,15 @@
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpKernel\DataCollector\DataCollector;
+use Symfony\Component\HttpKernel\DataCollector\LateDataCollectorInterface;
 use Symfony\Component\Messenger\TraceableMessageBus;
 
 /**
  * @author Samuel Roze <samuel.roze@gmail.com>
  *
  * @experimental in 4.1
  */
-class MessengerDataCollector extends DataCollector
+class MessengerDataCollector extends DataCollector implements LateDataCollectorInterface
 {
     private $traceableBuses = array();
 
@@ -34,6 +35,14 @@ public function registerBus(string $name, TraceableMessageBus $bus)
      * {@inheritdoc}
      */
     public function collect(Request $request, Response $response, \Exception $exception = null)
+    {
+        // Noop. Everything is collected live by the traceable buses & cloned as late as possible.
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function lateCollect()
     {
         $this->data = array('messages' => array());
 
 
@@ -12,8 +12,6 @@
 namespace Symfony\Component\Messenger\Tests\DataCollector;
 
 use PHPUnit\Framework\TestCase;
-use Symfony\Component\HttpFoundation\Request;
-use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\Messenger\DataCollector\MessengerDataCollector;
 use Symfony\Component\Messenger\MessageBusInterface;
 use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
@@ -43,7 +41,7 @@ public function testHandle($returnedValue, $expected)
 
         $bus->dispatch($message);
 
-        $collector->collect(Request::create('/'), new Response());
+        $collector->lateCollect();
 
         $messages = $collector->getMessages();
         $this->assertCount(1, $messages);
@@ -120,7 +118,7 @@ public function testHandleWithException()
             // Ignore.
         }
 
-        $collector->collect(Request::create('/'), new Response());
+        $collector->lateCollect();
 
         $messages = $collector->getMessages();
         $this->assertCount(1, $messages);