Merge pull request #34 from gdubost/v2

Ajout d'une step la queue devrait etre vide
etna-alternance · Sep 26, 2018 · 3010097 · 3010097
2 parents 669988d + 6c975b1
commit 3010097
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)");
+        }
+    }
 }