ARCH-414 Remove deprecated keys

ecentria · Nov 15, 2024 · bed98f6 · bed98f6
1 parent 350f461
commit bed98f6
Showing 1 changed file with 15 additions and 8 deletions.
diff --git a/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpExtIntegrationTest.php b/src/Symfony/Component/Messenger/Bridge/Amqp/Tests/Transport/AmqpExtIntegrationTest.php
@@ -144,9 +144,16 @@ public function testRetryAffectsOnlyOriginalQueue()
                 'default_publish_routing_key' => 'topic_routing_key',
             ],
             'queues' => [
-                'A' => ['binding_keys' => ['topic_routing_key']],
-                'B' => ['binding_keys' => ['topic_routing_key']],
-            ],
+                'A' => ['bindings' => [
+                    "binding1" => ['key' => "name1", "arguments" => ['arg1' => 'val1', 'arg2' => 'val2']],
+                    "binding2" => ['key' => "name2", "arguments" => ['arg3' => 'val3', 'arg4' => 'val4']]
+                ]],
+
+                'B' => ['bindings' => [
+                    "binding1" => ['key' => "name3", "arguments" => ['arg1' => 'val1', 'arg2' => 'val2']],
+                    "binding2" => ['key' => "name4", "arguments" => ['arg3' => 'val3', 'arg4' => 'val4']]
+                ]],
+            ]
         ]);
         $connection->setup();
         $connection->purgeQueues();
@@ -185,9 +192,9 @@ public function testItReceivesSignals()
         $sender->send(new Envelope(new DummyMessage('Hello')));
 
         $amqpReadTimeout = 30;
-        $dsn = getenv('MESSENGER_AMQP_DSN').'?read_timeout='.$amqpReadTimeout;
-        $process = new PhpProcess(file_get_contents(__DIR__.'/../Fixtures/long_receiver.php'), null, [
-            'COMPONENT_ROOT' => __DIR__.'/../../',
+        $dsn = getenv('MESSENGER_AMQP_DSN') . '?read_timeout=' . $amqpReadTimeout;
+        $process = new PhpProcess(file_get_contents(__DIR__ . '/../Fixtures/long_receiver.php'), null, [
+            'COMPONENT_ROOT' => __DIR__ . '/../../',
             'DSN' => $dsn,
         ]);
 
@@ -211,7 +218,7 @@ public function testItReceivesSignals()
         // make sure the process exited, after consuming only the 1 message
         $this->assertFalse($process->isRunning());
         $this->assertLessThan($amqpReadTimeout, microtime(true) - $signalTime);
-        $this->assertSame($expectedOutput.<<<'TXT'
+        $this->assertSame($expectedOutput . <<<'TXT'
 Get envelope with message: Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage
 with stamps: [
     "Symfony\\Component\\Messenger\\Stamp\\SerializedMessageStamp",
@@ -256,7 +263,7 @@ private function waitForOutput(Process $process, string $output, $timeoutInSecon
             usleep(100 * 1000); // 100ms
         }
 
-        throw new \RuntimeException('Expected output never arrived. Got "'.$process->getOutput().'" instead.');
+        throw new \RuntimeException('Expected output never arrived. Got "' . $process->getOutput() . '" instead.');
     }
 
     private function createSerializer(): SerializerInterface