[amqp-bunny] purge queues in specs.

Author: makasim

pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDelayPluginStrategyTest.php

@@ -3,8 +3,8 @@
 namespace Enqueue\AmqpBunny\Tests\Spec;
 
 use Enqueue\AmqpBunny\AmqpConnectionFactory;
+use Enqueue\AmqpBunny\AmqpContext;
 use Enqueue\AmqpTools\RabbitMqDelayPluginDelayStrategy;
-use Interop\Amqp\AmqpContext;
 use Interop\Queue\PsrContext;
 use Interop\Queue\Spec\SendAndReceiveDelayedMessageFromQueueSpec;
 
@@ -30,9 +30,9 @@ protected function createContext()
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param AmqpContext $context
+     *
+     * {@inheritdoc}
      */
     protected function createQueue(PsrContext $context, $queueName)
     {

pkg/amqp-bunny/Tests/Spec/AmqpSendAndReceiveDelayedMessageWithDlxStrategyTest.php

@@ -3,6 +3,7 @@
 namespace Enqueue\AmqpBunny\Tests\Spec;
 
 use Enqueue\AmqpBunny\AmqpConnectionFactory;
+use Enqueue\AmqpBunny\AmqpContext;
 use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
 use Interop\Queue\PsrContext;
 use Interop\Queue\Spec\SendAndReceiveDelayedMessageFromQueueSpec;
@@ -24,13 +25,16 @@ protected function createContext()
     }
 
     /**
+     * @param AmqpContext $context
+     *
      * {@inheritdoc}
      */
     protected function createQueue(PsrContext $context, $queueName)
     {
         $queue = parent::createQueue($context, $queueName);
 
         $context->declareQueue($queue);
+        $context->purgeQueue($queue);
 
         return $queue;
     }