fix bugs.

Author: makasim

DependencyInjection/EnqueueExtension.php renamed to DependencyInjection/EnqueueElasticaExtension.php

@@ -1,5 +1,5 @@
 <?php
-namespace Enqueue\ElasticaBundle\Listener;
+namespace Enqueue\ElasticaBundle\Elastica;
 
 use Enqueue\Psr\Context;
 use Enqueue\Util\JSON;

Elastica/AsyncDoctrineOrmProvider.php

@@ -1,5 +1,109 @@
 # Enqueue Elastica Bundle
 
+Improves performance of `fos:elastica:populate` commands by distributing the work among consumers. 
+The performance gain depends on how much consumers you run. 
+For example 10 consumers may give you 5 to 7 times better performance.  
+
+## Installation
+
+Install packages using [composer](https://getcomposer.org/)
+
+```bash
+$ composer require enqueue/elastica-bundle friendsofsymfony/elastica-bundle
+```
+
+Add bundles to `AppKernel`
+
+```php
+<?php
+use Symfony\Component\HttpKernel\Kernel;
+
+class AppKernel extends Kernel
+{
+    public function registerBundles()
+    {
+        $bundles = [
+            // ...
+            
+            new Enqueue\Bundle\EnqueueBundle(),
+            new Enqueue\ElasticaBundle\EnqueueElasticaBundle(),
+            new FOS\ElasticaBundle\FOSElasticaBundle(),
+        ];
+        
+        return $bundles;
+    }
+}
+```
+
+Here's an example of what your `FOSElasticaBundle` configuration may look like:
+
+```yaml
+fos_elastica:
+    clients:
+        default: { host: %elasticsearch_host%, port: %elasticsearch_port% }
+    indexes:
+        app:
+            index_name: app_%kernel.environment%
+            types:
+                blog:
+                    mappings:
+                        text: ~
+                    persistence:
+                        driver: orm
+                        model: AppBundle\Entity\Blog
+                        provider: ~
+                        listener: ~
+                        finder: ~
+```
+
+Here's an example of what your EnqueueBundle configuration may look like:
+
+```yaml
+enqueue:
+    transport:
+        default: 'amqp'
+        amqp:
+            host: '%rabbitmq_host%'
+            port: '%rabbitmq_port%'
+            login: '%rabbitmq_user%'
+            password: '%rabbitmq_password%'
+            vhost: '%rabbitmq_vhost%'
+```
+
+Create a `fos_elastica.populate` queue on broker side, if needed.
+
+## Usage 
+
+The bundle once registered automatically replaces Doctrine ORM provider by async one. 
+So you have to run as usual 
+ 
+```bash
+$ ./bin/console fos:elastica:populate 
+```
+
+and have pull of consumer commands run somewhere, run them as many as you'd like
+ 
+```bash
+$ ./bin/console enqueue:transport:consume fos_elastica.populate enqueue_elastica.populate_processor 
+```
+
+We suggest to use [supervisor](http://supervisord.org/) on production to control numbers of consumers and restart them.   
+
+Here's config example
+
+```
+# cat /etc/supervisor/conf.d/fos_elastica_populate.conf 
+[program:fos_elastica_populate]
+command=/mqs/symfony/bin/console enqueue:transport:consume fos_elastica.populate enqueue_elastica.populate_processor
+process_name=%(program_name)s_%(process_num)02d
+numprocs=10
+autostart=true
+autorestart=true
+startsecs=0
+user=root
+redirect_stderr=true
+```
+
 ## License
 
 It is released under the [MIT License](LICENSE).

README.md

@@ -1,10 +1,10 @@
 services:
-  enqueue_elastica.async.elastica_populate_processor:
+  enqueue_elastica.populate_processor:
       class: 'Enqueue\ElasticaBundle\Async\ElasticaPopulateProcessor'
       arguments:
           - '@fos_elastica.provider_registry'
 
-  app.listener.purge_fos_elastic_populate_queue:
+  enqueue_elastica.purge_fos_elastic_populate_queue_listener:
       class: 'Enqueue\ElasticaBundle\Listener\PurgeFosElasticPopulateQueueListener'
       arguments:
           - '@enqueue.transport.context'