Async event dispatcher pkg.

Author: makasim

composer.json

@@ -19,6 +19,7 @@
     "enqueue/job-queue": "*@dev",
     "enqueue/simple-client": "*@dev",
     "enqueue/test": "*@dev",
+    "enqueue/async-event-dispatcher": "*@dev",
 
     "phpunit/phpunit": "^5",
     "doctrine/doctrine-bundle": "~1.2",
@@ -98,6 +99,10 @@
     {
       "type": "path",
       "url": "pkg/simple-client"
+    },
+    {
+      "type": "path",
+      "url": "pkg/async-event-dispatcher"
     }
   ]
 }

docs/bundle/async_events.md

@@ -66,7 +66,7 @@ You can also add an async listener directly and register a custom message proces
 
 services:
     acme.async_foo_listener:
-        class: 'Enqueue\Bundle\Events\AsyncListener'
+        class: 'Enqueue\AsyncEventDispatcher\AsyncListener'
         public: false
         arguments: ['@enqueue.client.producer', '@enqueue.events.registry']
         tags:
@@ -78,7 +78,7 @@ The message processor must subscribe to `event.foo` topic. The message queue top
 ```php
 <?php
 
-use Enqueue\Bundle\Events\Registry;
+use Enqueue\AsyncEventDispatcher\Registry;
 use Enqueue\Client\TopicSubscriberInterface;
 use Enqueue\Psr\PsrContext;
 use Enqueue\Psr\PsrMessage;
@@ -126,7 +126,7 @@ class FooEventProcessor implements PsrProcessor, TopicSubscriberInterface
 ## Event transformer
 
 The bundle uses [php serializer](https://github.com/php-enqueue/enqueue-dev/blob/master/pkg/enqueue-bundle/Events/PhpSerializerEventTransformer.php) transformer by default to pass events through MQ.
-You could create a transformer for the given event type. The transformer must implement `Enqueue\Bundle\Events\EventTransformer` interface.
+You could create a transformer for the given event type. The transformer must implement `Enqueue\AsyncEventDispatcher\EventTransformer` interface.
 Consider the next example. It shows how to send an event that contains Doctrine entity as a subject  
 
 ```php
@@ -140,7 +140,7 @@ use Enqueue\Consumption\Result;
 use Enqueue\Psr\PsrMessage;
 use Enqueue\Util\JSON;
 use Symfony\Component\EventDispatcher\Event;
-use Enqueue\Bundle\Events\EventTransformer;
+use Enqueue\AsyncEventDispatcher\EventTransformer;
 use Doctrine\Bundle\DoctrineBundle\Registry;
 use Symfony\Component\EventDispatcher\GenericEvent;
 

phpunit.xml.dist

@@ -68,6 +68,10 @@
         <testsuite name="simple-client">
             <directory>pkg/simple-client/Tests</directory>
         </testsuite>
+
+        <testsuite name="async-event-dispatcher">
+            <directory>pkg/async-event-dispatcher/Tests</directory>
+        </testsuite>
     </testsuites>
 
     <filter>

pkg/async-event-dispatcher/.gitignore

@@ -0,0 +1,6 @@
+*~
+/composer.lock
+/composer.phar
+/phpunit.xml
+/vendor/
+/.idea/

pkg/async-event-dispatcher/.travis.yml

@@ -0,0 +1,21 @@
+sudo: false
+
+git:
+    depth: 1
+
+language: php
+
+php:
+    - '5.6'
+    - '7.0'
+
+cache:
+    directories:
+        - $HOME/.composer/cache
+
+install:
+    - composer self-update
+    - composer install --prefer-source --ignore-platform-reqs
+
+script:
+    - vendor/bin/phpunit --exclude-group=functional

pkg/enqueue-bundle/Events/AsyncListener.php renamed to pkg/async-event-dispatcher/AsyncListener.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Enqueue\Bundle\Events;
+namespace Enqueue\AsyncEventDispatcher;
 
 use Enqueue\Client\Message;
 use Enqueue\Client\ProducerInterface;

pkg/enqueue-bundle/Events/AsyncProcessor.php renamed to pkg/async-event-dispatcher/AsyncProcessor.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Enqueue\Bundle\Events;
+namespace Enqueue\AsyncEventDispatcher;
 
 use Enqueue\Consumption\Result;
 use Enqueue\Psr\PsrContext;

pkg/enqueue-bundle/Events/ContainerAwareRegistry.php renamed to pkg/async-event-dispatcher/ContainerAwareRegistry.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Enqueue\Bundle\Events;
+namespace Enqueue\AsyncEventDispatcher;
 
 use Symfony\Component\DependencyInjection\ContainerAwareInterface;
 use Symfony\Component\DependencyInjection\ContainerAwareTrait;

pkg/async-event-dispatcher/DependencyInjection/AsyncEventDispatcherExtension.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Enqueue\AsyncEventDispatcher\DependencyInjection;
+
+use Enqueue\AsyncEventDispatcher\OldProxyEventDispatcher;
+use Symfony\Component\Config\FileLocator;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Definition;
+use Symfony\Component\DependencyInjection\Extension\Extension;
+use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
+use Symfony\Component\DependencyInjection\Reference;
+use Symfony\Component\HttpKernel\Kernel;
+
+class AsyncEventDispatcherExtension extends Extension
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function load(array $configs, ContainerBuilder $container)
+    {
+        $loader = new YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
+        $loader->load('services.yml');
+
+        if (version_compare(Kernel::VERSION, '3.3', '<')) {
+            $container->setDefinition('enqueue.events.async_processor', new Definition(OldProxyEventDispatcher::class, [
+                new Reference('service_container'),
+                new Reference('enqueue.events.registry'),
+                new Reference('enqueue.events.event_dispatcher'),
+            ]));
+        }
+    }
+}

pkg/enqueue-bundle/Events/DependencyInjection/AsyncEventsPass.php renamed to pkg/async-event-dispatcher/DependencyInjection/AsyncEventsPass.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Enqueue\Bundle\Events\DependencyInjection;
+namespace Enqueue\AsyncEventDispatcher\DependencyInjection;
 
 use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;