symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpReceiver.php
Lines changed: 1 addition & 1 deletion b/‎src/Symfony/Component/Messenger/Bridge/Amqp/Transport/AmqpReceiver.php
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Symfony/Component/Messenger/Tests/WorkerTest.php
Lines changed: 6 additions & 4 deletions b/‎src/Symfony/Component/Messenger/Tests/WorkerTest.php
Lines changed: 6 additions & 4 deletions
diff --git a/‎src/Symfony/Component/Messenger/Transport/Receiver/QueueReceiverInterface.php
Lines changed: 3 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Transport/Receiver/QueueReceiverInterface.php
Lines changed: 3 additions & 1 deletion
@@ -26,7 +26,7 @@
  *
  * @author Samuel Roze <samuel.roze@gmail.com>
  */
-class AmqpReceiver implements ReceiverInterface, QueueReceiverInterface, MessageCountAwareInterface
+class AmqpReceiver implements QueueReceiverInterface, MessageCountAwareInterface
 {
     private $serializer;
     private $connection;
 
@@ -249,8 +249,8 @@ public function testWorkerWithMultipleReceivers()
 
     public function testWorkerLimitQueues()
     {
-        $receiver1 = $this->createMock(QueueReceiverInterface::class);
-        $receiver1->expects($this->once())
+        $receiver = $this->createMock(QueueReceiverInterface::class);
+        $receiver->expects($this->once())
             ->method('getFromQueues')
             ->with(['foo'])
             ->willReturn([new Envelope(new DummyMessage('message1'))])
@@ -261,8 +261,9 @@ public function testWorkerLimitQueues()
         $dispatcher = new EventDispatcher();
         $dispatcher->addSubscriber(new StopWorkerOnMessageLimitListener(1));
 
-        $worker = new Worker([$receiver1], $bus, $dispatcher);
+        $worker = new Worker([$receiver], $bus, $dispatcher);
         $this->expectException(RuntimeException::class);
+        $this->expectExceptionMessage();
         $worker->run(['queues' => ['foo']]);
     }
 
@@ -273,8 +274,9 @@ public function testWorkerLimitQueuesUnsupported()
 
         $bus = $this->getMockBuilder(MessageBusInterface::class)->getMock();
 
-        $worker = new Worker([$receiver1, $receiver2], $bus);
+        $worker = new Worker(['transport1' => $receiver1, 'transport2' => $receiver2], $bus);
         $this->expectException(RuntimeException::class);
+        $this->expectExceptionMessage('Receiver for transport2 does not implement '.QueueReceiverInterface::class);
         $worker->run(['queues' => ['foo']]);
     }
 
 
@@ -17,8 +17,10 @@
  * Some transports may have multiple queues. This interface is used to read from only some queues.
  *
  * @author David Buchmann <mail@davidbu.ch>
+ *
+ * @experimental in 5.3
  */
-interface QueueReceiverInterface
+interface QueueReceiverInterface extends ReceiverInterface
 {
     /**
      * Get messages from the specified queue names instead of consuming from all queues.
Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@`
`26`	`26`	`*`
`27`	`27`	`* @author Samuel Roze <samuel.roze@gmail.com>`
`28`	`28`	`*/`
`29`		`-class AmqpReceiver implements ReceiverInterface, QueueReceiverInterface, MessageCountAwareInterface`
	`29`	`+class AmqpReceiver implements QueueReceiverInterface, MessageCountAwareInterface`
`30`	`30`	`{`
`31`	`31`	`private $serializer;`
`32`	`32`	`private $connection;`
Original file line number	Diff line number	Diff line change
`@@ -17,8 +17,10 @@`
`17`	`17`	`* Some transports may have multiple queues. This interface is used to read from only some queues.`
`18`	`18`	`*`
`19`	`19`	`* @author David Buchmann <mail@davidbu.ch>`
	`20`	`+ *`
	`21`	`+ * @experimental in 5.3`
`20`	`22`	`*/`
`21`		`-interface QueueReceiverInterface`
	`23`	`+interface QueueReceiverInterface extends ReceiverInterface`
`22`	`24`	`{`
`23`	`25`	`/**`
`24`	`26`	`* Get messages from the specified queue names instead of consuming from all queues.`