add subscription consumer specs to amqp pkgs

Author: makasim

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

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpBunny\Tests\Spec;
+
+use Enqueue\AmqpBunny\AmqpConnectionFactory;
+use Enqueue\AmqpBunny\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec;
+
+class AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest extends SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

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

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpBunny\Tests\Spec;
+
+use Enqueue\AmqpBunny\AmqpConnectionFactory;
+use Interop\Amqp\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeUntilUnsubscribedSpec;
+
+class AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest extends SubscriptionConsumerConsumeUntilUnsubscribedSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

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

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpBunny\Tests\Spec;
+
+use Enqueue\AmqpBunny\AmqpConnectionFactory;
+use Interop\Amqp\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerStopOnFalseSpec;
+
+class AmqpSubscriptionConsumerStopOnFalseTest extends SubscriptionConsumerStopOnFalseSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

pkg/amqp-bunny/composer.json

@@ -16,7 +16,7 @@
         "enqueue/test": "0.9.x-dev",
         "enqueue/enqueue": "0.9.x-dev",
         "enqueue/null": "0.9.x-dev",
-        "queue-interop/queue-spec": "^0.5.3@dev",
+        "queue-interop/queue-spec": "^0.5.8@dev",
         "symfony/dependency-injection": "^3.4|^4",
         "symfony/config": "^3.4|^4"
     },

pkg/amqp-ext/Tests/Spec/AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpExt\Tests\Spec;
+
+use Enqueue\AmqpExt\AmqpConnectionFactory;
+use Enqueue\AmqpExt\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec;
+
+class AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest extends SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

pkg/amqp-ext/Tests/Spec/AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpExt\Tests\Spec;
+
+use Enqueue\AmqpExt\AmqpConnectionFactory;
+use Interop\Amqp\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeUntilUnsubscribedSpec;
+
+class AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest extends SubscriptionConsumerConsumeUntilUnsubscribedSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

pkg/amqp-ext/Tests/Spec/AmqpSubscriptionConsumerStopOnFalseTest.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpExt\Tests\Spec;
+
+use Enqueue\AmqpExt\AmqpConnectionFactory;
+use Interop\Amqp\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerStopOnFalseSpec;
+
+class AmqpSubscriptionConsumerStopOnFalseTest extends SubscriptionConsumerStopOnFalseSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

pkg/amqp-ext/composer.json

@@ -16,7 +16,7 @@
         "enqueue/test": "0.9.x-dev",
         "enqueue/enqueue": "0.9.x-dev",
         "enqueue/null": "0.9.x-dev",
-        "queue-interop/queue-spec": "^0.5.3@dev",
+        "queue-interop/queue-spec": "^0.5.8@dev",
         "empi89/php-amqp-stubs": "*@dev",
         "symfony/dependency-injection": "^3.4|^4",
         "symfony/config": "^3.4|^4"

pkg/amqp-lib/Tests/Spec/AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpLib\Tests\Spec;
+
+use Enqueue\AmqpLib\AmqpConnectionFactory;
+use Enqueue\AmqpLib\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec;
+
+class AmqpSubscriptionConsumerConsumeFromAllSubscribedQueuesTest extends SubscriptionConsumerConsumeFromAllSubscribedQueuesSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}

pkg/amqp-lib/Tests/Spec/AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Enqueue\AmqpLib\Tests\Spec;
+
+use Enqueue\AmqpLib\AmqpConnectionFactory;
+use Interop\Amqp\AmqpContext;
+use Interop\Amqp\AmqpQueue;
+use Interop\Queue\PsrContext;
+use Interop\Queue\Spec\SubscriptionConsumerConsumeUntilUnsubscribedSpec;
+
+class AmqpSubscriptionConsumerConsumeUntilUnsubscribedTest extends SubscriptionConsumerConsumeUntilUnsubscribedSpec
+{
+    /**
+     * @return AmqpContext
+     *
+     * {@inheritdoc}
+     */
+    protected function createContext()
+    {
+        $factory = new AmqpConnectionFactory(getenv('AMQP_DSN'));
+
+        $context = $factory->createContext();
+        $context->setQos(0, 5, false);
+
+        return $context;
+    }
+
+    /**
+     * @param AmqpContext $context
+     *
+     * {@inheritdoc}
+     */
+    protected function createQueue(PsrContext $context, $queueName)
+    {
+        /** @var AmqpQueue $queue */
+        $queue = parent::createQueue($context, $queueName);
+        $context->declareQueue($queue);
+        $context->purgeQueue($queue);
+
+        return $queue;
+    }
+}