Ajout d'une step la queue devrait etre vide

etna-alternance · Sep 26, 2018 · 6c975b1 · 6c975b1
1 parent 669988d
commit 6c975b1
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/src/RabbitContext.php b/src/RabbitContext.php
@@ -191,4 +191,18 @@ public function ilDoitYAvoirUnMessageDansLaFileAvecLeCorpsContenuDans($queue = n
         $this->check($parsed_wanted, $parsed_response, "result", $errors);
         $this->handleErrors($parsed_response, $errors);
     }
+
+    /**
+     * @Then la queue ":queue_name" devrait être vide
+     */
+    public function laQueueDevraitEtreVide($queue_name)
+    {
+        $channel = self::$silex_app["rabbit.connection"]['default']->channel();
+
+        list($queue, $message_count, $consumer_count) = $channel->queue_declare($queue_name, true);
+
+        if (0 !== $message_count) {
+            throw new \Exception("Expecting {$queue_name} to be empty, but found {$message_count} job(s)");
+        }
+    }
 }