Merge pull request #142 from enesaktay/add-configuration

Add the functionality to configurate any message queue

README.md

@@ -70,6 +70,22 @@ sylius_import_export:
     prefix: /admin
 ```
 
+### Message queue configuration:
+Any library implementing the **"queue-interop/queue-interop"** can be used as the message queue. Following is the "enqueue/redis" library shown as an example usage.
+```yaml
+# define a service which will be used as the queue
+services:
+    redis_connection_factory:
+        class: Enqueue\Redis\RedisConnectionFactory
+```
+
+```yaml
+# use the defined service
+fos_sylius_import_export:
+    message_queue:
+        service_id: 'redis_connection_factory'
+```
+
 ## Usage
 
 ### Available importer types

composer.json

@@ -7,23 +7,23 @@
         "php": "^7.1",
         "sylius/sylius": "^1.0",
         "portphp/portphp": "^1.2",
-        "symfony/stopwatch": "^3.3"
+        "symfony/stopwatch": "^3.3",
+        "queue-interop/queue-interop": "^0.6.2"
     },
     "suggest": {
         "portphp/excel": "To support importing excel files, use version ^1.1",
         "ext-zip": "To support writing of Excel files",
         "portphp/csv": "To support importing csv files, use version ^1.1",
-        "enqueue/enqueue-bundle" : "To support message queuing",
-        "enqueue/redis" : "To support message queuing",
-        "predis/predis" : "To support message queuing"
+        "enqueue/enqueue-bundle" : "To help defining message queuing services",
+        "enqueue/redis" : "To support message queuing via redis",
+        "enqueue/sqs" : "To support message queuing via sqs"
     },
     "require-dev": {
         "behat/behat": "^3.3",
         "behat/mink": "^1.7",
         "behat/mink-browserkit-driver": "^1.3",
         "behat/mink-extension": "^2.2",
         "behat/mink-selenium2-driver": "^1.3",
-        "enqueue/enqueue-bundle": "^0.8.31",
         "enqueue/redis": "^0.8.23",
         "friends-of-behat/context-service-extension": "^1.0",
         "friends-of-behat/cross-container-extension": "^1.0",