AMQP purge queues on init

Yegor Tokmakov · Yegor Tokmakov · commit f6189522e7ff · 2014-11-10T16:51:45.000+01:00
diff --git a/src/Codeception/Module/AMQP.php b/src/Codeception/Module/AMQP.php
@@ -190,7 +190,6 @@ protected function cleanup()
             throw new ModuleException(__CLASS__, "please set queues for cleanup");
         }
         if (!$this->connection) return;
-        if ($this->connection->channel()->is_open) return;
         foreach ($this->config['queues'] as $queue) {
             try {
                 $this->connection->channel()->queue_purge($queue);

Original file line number	Diff line number	Diff line change
`@@ -190,7 +190,6 @@ protected function cleanup()`
`190`	`190`	`throw new ModuleException(__CLASS__, "please set queues for cleanup");`
`191`	`191`	`}`
`192`	`192`	`if (!$this->connection) return;`
`193`		`- if ($this->connection->channel()->is_open) return;`
`194`	`193`	`foreach ($this->config['queues'] as $queue) {`
`195`	`194`	`try {`
`196`	`195`	`$this->connection->channel()->queue_purge($queue);`