add a parameter to enable subscription consumer

Author: makasim

pkg/amqp-tools/SubscriptionConsumer.php

@@ -6,6 +6,9 @@
 use Interop\Queue\PsrConsumer;
 use Interop\Queue\PsrSubscriptionConsumer;
 
+/**
+ * @deprecated this is BC layer, will be removed in 0.9
+ */
 final class SubscriptionConsumer implements PsrSubscriptionConsumer
 {
     /**

pkg/enqueue-bundle/Resources/config/services.yml

@@ -1,3 +1,8 @@
+parameters:
+  enqueue.queue_consumer.enable_subscription_consumer: false
+  enqueue.queue_consumer.default_idle_time: 0
+  enqueue.queue_consumer.default_receive_timeout: 10
+
 services:
     enqueue.consumption.extensions:
         class: 'Enqueue\Consumption\ChainExtension'
@@ -11,8 +16,10 @@ services:
         arguments:
             - '@enqueue.transport.context'
             - '@enqueue.consumption.extensions'
-            - ~
-            - ~
+            - '%enqueue.queue_consumer.default_idle_time%'
+            - '%enqueue.queue_consumer.default_receive_timeout%'
+        calls:
+            - ['enableSubscriptionConsumer', ['%enqueue.queue_consumer.enable_subscription_consumer%']]
 
     # Deprecated. To be removed in 0.10.
     enqueue.consumption.queue_consumer:

pkg/enqueue-bundle/composer.json

@@ -8,7 +8,7 @@
     "require": {
         "php": ">=5.6",
         "symfony/framework-bundle": "^2.8|^3|^4",
-        "enqueue/enqueue": "^0.8@dev",
+        "enqueue/enqueue": "^0.8.34@dev",
         "enqueue/null": "^0.8@dev",
         "enqueue/async-event-dispatcher": "^0.8@dev"
     },