magento enqueue

Author: ASKozienko

src/Enqueue/Enqueue/Model/Config/Source/Redis/Vendor.php

@@ -0,0 +1,17 @@
+<?php
+
+class Enqueue_Enqueue_Model_Config_Source_Redis_Vendor
+{
+    /**
+     * Options getter
+     *
+     * @return array
+     */
+    public function toOptionArray()
+    {
+        return [
+            ['value' => 'phpredis', 'label' => Mage::helper('enqueue')->__('phpredis')],
+            ['value' => 'predis', 'label' => Mage::helper('enqueue')->__('predis')],
+        ];
+    }
+}

src/Enqueue/Enqueue/Model/Config/Source/Transport.php

@@ -10,7 +10,14 @@ class Enqueue_Enqueue_Model_Config_Source_Transport
     public function toOptionArray()
     {
         return [
-            ['value' => 'rabbitmq-amqp', 'label' => Mage::helper('enqueue')->__('RabbitMQ AMQP')],
+            ['value' => 'rabbitmq_amqp', 'label' => Mage::helper('enqueue')->__('RabbitMQ AMQP')],
+            ['value' => 'amqp', 'label' => Mage::helper('enqueue')->__('AMQP')],
+            ['value' => 'rabbitmq_stomp', 'label' => Mage::helper('enqueue')->__('RabbitMQ STOMP')],
+            ['value' => 'stomp', 'label' => Mage::helper('enqueue')->__('STOMP')],
+            ['value' => 'fs', 'label' => Mage::helper('enqueue')->__('Filesystem')],
+            ['value' => 'sqs', 'label' => Mage::helper('enqueue')->__('Amazon AWS SQS')],
+            ['value' => 'redis', 'label' => Mage::helper('enqueue')->__('Redis')],
+            ['value' => 'dbal', 'label' => Mage::helper('enqueue')->__('Doctrine DBAL')],
         ];
     }
 }

src/Enqueue/Enqueue/etc/config.xml

@@ -22,13 +22,6 @@
             <transport>
                 <default>rabbitmq-amqp</default>
             </transport>
-            <rabbitmq>
-                <host>localhost</host>
-                <port>5672</port>
-                <login>guest</login>
-                <password>guest</password>
-                <vhost>/</vhost>
-            </rabbitmq>
             <client>
                 <prefix>enqueue</prefix>
                 <app_name>app</app_name>
@@ -37,6 +30,31 @@
                 <default_processor_queue>default</default_processor_queue>
                 <redelivered_delay_time>0</redelivered_delay_time>
             </client>
+            <rabbitmq_amqp>
+                <host>localhost</host>
+                <port>5672</port>
+                <login>guest</login>
+                <password>guest</password>
+                <vhost>/</vhost>
+                <lazy>1</lazy>
+                <delay_plugin_installed>0</delay_plugin_installed>
+            </rabbitmq_amqp>
+            <fs>
+                <pre_fetch_count>1</pre_fetch_count>
+                <chmod>0600</chmod>
+            </fs>
+            <sqs>
+                <retries>3</retries>
+                <lazy>1</lazy>
+            </sqs>
+            <redis>
+                <lazy>1</lazy>
+            </redis>
+            <dbal>
+                <table_name>enqueue</table_name>
+                <polling_interval>1000</polling_interval>
+                <lazy>1</lazy>
+            </dbal>
         </enqueue>
     </default>
 </config>