symfony
diff --git a/‎src/Symfony/Component/Messenger/Tests/WorkerTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/WorkerTest.php
+1-1Lines changed: 1 addition & 1 deletion b/‎src/Symfony/Component/Messenger/Tests/WorkerTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/WorkerTest.php
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎src/Symfony/Component/Messenger/Worker.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Worker.php
+1-1Lines changed: 1 addition & 1 deletion b/‎src/Symfony/Component/Messenger/Worker.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Worker.php
+1-1Lines changed: 1 addition & 1 deletion
@@ -278,7 +278,7 @@ public function testWorkerLimitQueuesUnsupported()
 
         $worker = new Worker(['transport1' => $receiver1, 'transport2' => $receiver2], $bus);
         $this->expectException(RuntimeException::class);
-        $this->expectExceptionMessage(sprintf('Receiver for transport2 does not implement %s', QueueReceiverInterface::class));
+        $this->expectExceptionMessage(sprintf('Receiver for "transport2" does not implement "%s".', QueueReceiverInterface::class));
         $worker->run(['queues' => ['foo']]);
     }
 
 
@@ -74,7 +74,7 @@ public function run(array $options = []): void
             // if queue names are specified, all receivers must implement the QueueReceiverInterface
             foreach ($this->receivers as $transportName => $receiver) {
                 if (!$receiver instanceof QueueReceiverInterface) {
-                    throw new RuntimeException(sprintf('Receiver for "%s" does not implement %s', $transportName, QueueReceiverInterface::class));
+                    throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));
                 }
             }
         }
Original file line number	Diff line number	Diff line change
`@@ -278,7 +278,7 @@ public function testWorkerLimitQueuesUnsupported()`
`278`	`278`
`279`	`279`	`$worker = new Worker(['transport1' => $receiver1, 'transport2' => $receiver2], $bus);`
`280`	`280`	`$this->expectException(RuntimeException::class);`
`281`		`- $this->expectExceptionMessage(sprintf('Receiver for transport2 does not implement %s', QueueReceiverInterface::class));`
	`281`	`+ $this->expectExceptionMessage(sprintf('Receiver for "transport2" does not implement "%s".', QueueReceiverInterface::class));`
`282`	`282`	`$worker->run(['queues' => ['foo']]);`
`283`	`283`	`}`
`284`	`284`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ public function run(array $options = []): void`
`74`	`74`	`// if queue names are specified, all receivers must implement the QueueReceiverInterface`
`75`	`75`	`foreach ($this->receivers as $transportName => $receiver) {`
`76`	`76`	`if (!$receiver instanceof QueueReceiverInterface) {`
`77`		`- throw new RuntimeException(sprintf('Receiver for "%s" does not implement %s', $transportName, QueueReceiverInterface::class));`
	`77`	`+ throw new RuntimeException(sprintf('Receiver for "%s" does not implement "%s".', $transportName, QueueReceiverInterface::class));`
`78`	`78`	`}`
`79`	`79`	`}`
`80`	`80`	`}`