We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4539f75 commit d68163cCopy full SHA for d68163c
src/Codeception/Module/AMQP.php
@@ -55,7 +55,8 @@ class AMQP extends CodeceptionModule implements RequiresPackage
55
'port' => '5672',
56
'vhost' => '/',
57
'cleanup' => true,
58
- 'single_channel' => false
+ 'single_channel' => false,
59
+ 'queues' => []
60
];
61
62
/**
@@ -276,6 +277,18 @@ public function bindQueueToExchange(
276
277
);
278
}
279
280
+ /**
281
+ * Add a queue to purge list
282
+ *
283
+ * @param string $queue
284
+ */
285
+ public function scheduleQueueCleanup($queue)
286
+ {
287
+ if (!in_array($queue, $this->config['queues'])) {
288
+ $this->config['queues'][] = $queue;
289
+ }
290
291
+
292
293
* Checks if message containing text received.
294
*
0 commit comments