B2B-1816: AWS Managed Queue: Get Cloud-Native-Testing Integration Test Builds to Work Against AWS Managed Queue

Author: joanhe

dev/tests/integration/framework/Magento/TestFramework/Helper/Amqp.php

@@ -18,6 +18,7 @@ class Amqp
     const CONFIG_PATH_PASSWORD = 'queue/amqp/password';
     const DEFAULT_MANAGEMENT_PROTOCOL = 'http';
     const DEFAULT_MANAGEMENT_PORT = '15672';
+    const DEFAULT_VIRTUALHOST = '/';
 
     /**
      * @var Curl
@@ -36,6 +37,13 @@ class Amqp
      */
     private $host;
 
+    /**
+     * RabbitMQ virtual host
+     *
+     * @var string
+     */
+    private $virtualHost;
+
     /**
      * Initialize dependencies.
      * @param \Magento\Framework\App\DeploymentConfig $deploymentConfig
@@ -59,6 +67,7 @@ public function __construct(
             $this->deploymentConfig->get(self::CONFIG_PATH_HOST),
             defined('RABBITMQ_MANAGEMENT_PORT') ? RABBITMQ_MANAGEMENT_PORT : self::DEFAULT_MANAGEMENT_PORT
         );
+        $this->virtualHost = defined('RABBITMQ_VIRTUALHOST') ? RABBITMQ_VIRTUALHOST : self::DEFAULT_VIRTUALHOST;
     }
 
     /**
@@ -82,7 +91,7 @@ public function isAvailable(): bool
      */
     public function getExchanges()
     {
-        $this->curl->get($this->host . 'exchanges');
+        $this->curl->get($this->host . 'exchanges/' . urlencode($this->virtualHost));
         $data = $this->curl->getBody();
         $data = json_decode($data, true);
         $output = [];
@@ -100,7 +109,7 @@ public function getExchanges()
      */
     public function getExchangeBindings($name)
     {
-        $this->curl->get($this->host . 'exchanges/%2f/' . $name . '/bindings/source');
+        $this->curl->get($this->host . 'exchanges/' . urlencode($this->virtualHost) . '/' . $name . '/bindings/source');
         $data = $this->curl->getBody();
         return json_decode($data, true);
     }
@@ -112,7 +121,7 @@ public function getExchangeBindings($name)
      */
     public function getConnections()
     {
-        $this->curl->get($this->host . 'connections');
+        $this->curl->get($this->host . 'vhosts/' . urlencode($this->virtualHost) . '/connections');
         $data = $this->curl->getBody();
         $data = json_decode($data, true);
         $output = [];
@@ -137,7 +146,9 @@ public function clearQueue(string $name, int $numMessages = 50)
             "encoding" => "auto",
             "truncate" => 50000
         ];
-        $this->curl->post($this->host . 'queue/%2f/' . $name . '/get', json_encode($body));
+        $this->curl->post(
+            $this->host . 'queue/' . urlencode($this->virtualHost) . '/' . $name . '/get', json_encode($body)
+        );
         return $this->curl->getBody();
     }
 

dev/tests/integration/phpunit.xml.dist

@@ -82,6 +82,7 @@
         <!-- Connection parameters for RabbitMQ tests -->
         <!--<const name="RABBITMQ_MANAGEMENT_PROTOCOL" value="https"/>-->
         <!--<const name="RABBITMQ_MANAGEMENT_PORT" value="15672"/>-->
+        <!--<const name="RABBITMQ_VIRTUALHOST" value="/"/>-->
         <!--<const name="TESTS_PARALLEL_RUN" value="1"/>-->
         <const name="USE_OVERRIDE_CONFIG" value="enabled"/>
     </php>