Merge pull request #130 from php-enqueue/migrate-to-queue-interop

Migrate to queue interop

Author: makasim

.travis.yml

@@ -55,7 +55,7 @@ install:
 
 script:
     # misssing pkg/amqp-ext pkg/job-queue pkg/redis
-    - if [ "$PHPSTAN" = true ]; then php -d memory_limit=512M bin/phpstan analyse -l 1 -c phpstan.neon pkg/amqp-ext pkg/async-event-dispatcher pkg/dbal pkg/enqueue pkg/enqueue-bundle pkg/fs pkg/gearman pkg/job-queue pkg/null pkg/pheanstalk pkg/psr-queue pkg/redis pkg/simple-client pkg/sqs pkg/stomp pkg/test; fi
+    - if [ "$PHPSTAN" = true ]; then php -d memory_limit=512M bin/phpstan analyse -l 1 -c phpstan.neon pkg/amqp-ext pkg/async-event-dispatcher pkg/dbal pkg/enqueue pkg/enqueue-bundle pkg/fs pkg/gearman pkg/job-queue pkg/null pkg/pheanstalk pkg/redis pkg/simple-client pkg/sqs pkg/stomp pkg/test; fi
     - if [ "$PHP_CS_FIXER" = true ]; then IFS=$'\n'; COMMIT_SCA_FILES=($(git diff --name-only --diff-filter=ACMRTUXB "${TRAVIS_COMMIT_RANGE}")); unset IFS; fi
     - if [ "$PHP_CS_FIXER" = true ]; then ./bin/php-cs-fixer fix --config=.php_cs.dist -v --dry-run --stop-on-violation --using-cache=no --path-mode=intersection -- "${COMMIT_SCA_FILES[@]}"; fi
     - if [ "$UNIT_TESTS" = true ]; then bin/phpunit --exclude-group=functional; fi

README.md

@@ -8,7 +8,7 @@ This is where all development happens. The repository provides a friendly enviro
 Features:
 
 * [Feature rich](docs/quick_tour.md).
-* [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transport [abstraction](https://github.com/php-enqueue/psr-queue).
+* Implements [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transports based on a[queue-interop](https://github.com/queue-interop/queue-interop) interfaces.
 * Supported  transports [AMQP](docs/transport/amqp.md) (RabbitMQ, ActiveMQ), [Beanstalk](docs/transport/pheanstalk.md),  [STOMP](docs/transport/stomp.md), [Amazon SQS](docs/transport/sqs.md), [Redis](docs/transport/redis.md), [Gearman](docs/transport/gearman.md), [Doctrine DBAL](docs/transport/dbal.md), [Filesystem](docs/transport/filesystem.md), [Null](docs/transport/null.md).
 * [Symfony bundle](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/bundle/quick_tour.md)
 * [Magento1 extension](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/magento/quick_tour.md)

bin/release

@@ -14,7 +14,7 @@ fi
 
 CURRENT_BRANCH=`git rev-parse --abbrev-ref HEAD`
 
-for REMOTE in origin psr-queue stomp amqp-ext pheanstalk gearman sqs fs redis dbal null enqueue simple-client enqueue-bundle job-queue test async-event-dispatcher
+for REMOTE in origin stomp amqp-ext pheanstalk gearman sqs fs redis dbal null enqueue simple-client enqueue-bundle job-queue test async-event-dispatcher
 do
     echo ""
     echo ""

bin/subtree-split

@@ -43,7 +43,6 @@ function remote()
     git remote add $1 $2 || true
 }
 
-remote psr-queue git@github.com:php-enqueue/psr-queue.git
 remote enqueue git@github.com:php-enqueue/enqueue.git
 remote simple-client git@github.com:php-enqueue/simple-client.git
 remote stomp git@github.com:php-enqueue/stomp.git
@@ -60,7 +59,6 @@ remote job-queue git@github.com:php-enqueue/job-queue.git
 remote test git@github.com:php-enqueue/test.git
 remote async-event-dispatcher git@github.com:php-enqueue/async-event-dispatcher.git
 
-split 'pkg/psr-queue' psr-queue
 split 'pkg/enqueue' enqueue
 split 'pkg/simple-client' simple-client
 split 'pkg/stomp' stomp

composer.json

@@ -4,7 +4,6 @@
   "minimum-stability": "stable",
   "require": {
     "php": ">=5.6",
-    "enqueue/psr-queue": "*@dev",
     "enqueue/enqueue": "*@dev",
     "enqueue/stomp": "*@dev",
     "enqueue/amqp-ext": "*@dev",
@@ -20,6 +19,8 @@
     "enqueue/simple-client": "*@dev",
     "enqueue/test": "*@dev",
     "enqueue/async-event-dispatcher": "*@dev",
+    "queue-interop/queue-interop": "^0.5@dev",
+    "queue-interop/queue-spec": "^0.5@dev",
 
     "phpunit/phpunit": "^5",
     "doctrine/doctrine-bundle": "~1.2",
@@ -40,10 +41,6 @@
     "bin-dir": "bin"
   },
   "repositories": [
-    {
-      "type": "path",
-      "url": "pkg/psr-queue"
-    },
     {
       "type": "path",
       "url": "pkg/test"

docs/async_event_dispatcher/quick_tour.md

@@ -33,7 +33,7 @@ use Symfony\Component\EventDispatcher\EventDispatcher;
 
 require_once __DIR__.'/vendor/autoload.php';
 
-// it could be any other enqueue/psr-queue compatible context.
+// it could be any other queue-interop/queue-interop compatible context.
 $context = (new FsConnectionFactory('file://'.__DIR__.'/queues'))->createContext();
 $eventQueue = $context->createQueue('symfony_events');
 
@@ -81,7 +81,7 @@ $dispatcher->dispatch('the_event', new GenericEvent('theSubject'));
 
 // consume.php
 
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 require_once __DIR__.'/vendor/autoload.php';
 include __DIR__.'/config.php';

docs/bundle/async_events.md

@@ -88,7 +88,7 @@ namespace AcmeBundle\Listener;
 
 use Enqueue\Client\Message;
 use Enqueue\Consumption\Result;
-use Enqueue\Psr\PsrMessage;
+use Interop\Queue\PsrMessage;
 use Enqueue\Util\JSON;
 use Symfony\Component\EventDispatcher\Event;
 use Enqueue\AsyncEventDispatcher\EventTransformer;

docs/bundle/job_queue.md

@@ -14,9 +14,9 @@ Guaranty that there is only single job running with such name.
 
 ```php
 <?php 
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrProcessor;
-use Enqueue\Psr\PsrContext;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrProcessor;
+use Interop\Queue\PsrContext;
 use Enqueue\Util\JSON;
 use Enqueue\JobQueue\JobRunner;
 use Enqueue\JobQueue\Job;
@@ -57,9 +57,9 @@ use Enqueue\JobQueue\JobRunner;
 use Enqueue\JobQueue\Job;
 use Enqueue\Client\ProducerInterface;
 use Enqueue\Util\JSON;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrProcessor;
 
 class Step1Processor implements PsrProcessor 
 {
@@ -140,9 +140,9 @@ use Enqueue\JobQueue\JobRunner;
 use Enqueue\JobQueue\Job;
 use Enqueue\JobQueue\DependentJobService;
 use Enqueue\Util\JSON;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrProcessor;
 
 class ReindexProcessor implements PsrProcessor 
 {

docs/bundle/message_processor.md

@@ -36,7 +36,7 @@ It is handy to subscribe on event messages. It allows to keep subscription login
 namespace AppBundle\Async;
 
 use Enqueue\Client\TopicSubscriberInterface;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 class SayHelloProcessor implements PsrProcessor, TopicSubscriberInterface
 {
@@ -52,7 +52,7 @@ On the topic subscriber you can also define queue and processor name:
 ```php
 <?php
 use Enqueue\Client\TopicSubscriberInterface;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 class SayHelloProcessor implements PsrProcessor, TopicSubscriberInterface
 {
@@ -89,7 +89,7 @@ If you send a message using ProducerV2::sendCommand('aCommandName') method it wi
 namespace AppBundle\Async;
 
 use Enqueue\Client\CommandSubscriberInterface;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 class SayHelloProcessor implements PsrProcessor, CommandSubscriberInterface
 {
@@ -105,7 +105,7 @@ On the command subscriber you can also define additional settings such as queue
 ```php
 <?php
 use Enqueue\Client\CommandSubscriberInterface;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 class SayHelloProcessor implements PsrProcessor, CommandSubscriberInterface
 {
@@ -124,7 +124,7 @@ In the container you can just add the tag `enqueue.client.message_processor` and
 ```php
 <?php
 use Enqueue\Client\CommandSubscriberInterface;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrProcessor;
 
 class SayHelloProcessor implements PsrProcessor, CommandSubscriberInterface
 {

docs/bundle/quick_tour.md

@@ -72,9 +72,9 @@ To consume messages you have to first create a message processor:
 
 ```php
 <?php
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrProcessor;
 use Enqueue\Client\TopicSubscriberInterface;
 
 class FooProcessor implements PsrProcessor, TopicSubscriberInterface