Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit 42a3f76

Browse files
magento enqueue
1 parent f0550c0 commit 42a3f76

File tree

4 files changed

+495
-34
lines changed

4 files changed

+495
-34
lines changed
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
<?php
2+
3+
class Enqueue_Enqueue_Model_Config_Source_Redis_Vendor
4+
{
5+
/**
6+
* Options getter
7+
*
8+
* @return array
9+
*/
10+
public function toOptionArray()
11+
{
12+
return [
13+
['value' => 'phpredis', 'label' => Mage::helper('enqueue')->__('phpredis')],
14+
['value' => 'predis', 'label' => Mage::helper('enqueue')->__('predis')],
15+
];
16+
}
17+
}

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,14 @@ class Enqueue_Enqueue_Model_Config_Source_Transport
1010
public function toOptionArray()
1111
{
1212
return [
13-
['value' => 'rabbitmq-amqp', 'label' => Mage::helper('enqueue')->__('RabbitMQ AMQP')],
13+
['value' => 'rabbitmq_amqp', 'label' => Mage::helper('enqueue')->__('RabbitMQ AMQP')],
14+
['value' => 'amqp', 'label' => Mage::helper('enqueue')->__('AMQP')],
15+
['value' => 'rabbitmq_stomp', 'label' => Mage::helper('enqueue')->__('RabbitMQ STOMP')],
16+
['value' => 'stomp', 'label' => Mage::helper('enqueue')->__('STOMP')],
17+
['value' => 'fs', 'label' => Mage::helper('enqueue')->__('Filesystem')],
18+
['value' => 'sqs', 'label' => Mage::helper('enqueue')->__('Amazon AWS SQS')],
19+
['value' => 'redis', 'label' => Mage::helper('enqueue')->__('Redis')],
20+
['value' => 'dbal', 'label' => Mage::helper('enqueue')->__('Doctrine DBAL')],
1421
];
1522
}
1623
}

‎src/Enqueue/Enqueue/etc/config.xml

Lines changed: 25 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,13 +22,6 @@
2222
<transport>
2323
<default>rabbitmq-amqp</default>
2424
</transport>
25-
<rabbitmq>
26-
<host>localhost</host>
27-
<port>5672</port>
28-
<login>guest</login>
29-
<password>guest</password>
30-
<vhost>/</vhost>
31-
</rabbitmq>
3225
<client>
3326
<prefix>enqueue</prefix>
3427
<app_name>app</app_name>
@@ -37,6 +30,31 @@
3730
<default_processor_queue>default</default_processor_queue>
3831
<redelivered_delay_time>0</redelivered_delay_time>
3932
</client>
33+
<rabbitmq_amqp>
34+
<host>localhost</host>
35+
<port>5672</port>
36+
<login>guest</login>
37+
<password>guest</password>
38+
<vhost>/</vhost>
39+
<lazy>1</lazy>
40+
<delay_plugin_installed>0</delay_plugin_installed>
41+
</rabbitmq_amqp>
42+
<fs>
43+
<pre_fetch_count>1</pre_fetch_count>
44+
<chmod>0600</chmod>
45+
</fs>
46+
<sqs>
47+
<retries>3</retries>
48+
<lazy>1</lazy>
49+
</sqs>
50+
<redis>
51+
<lazy>1</lazy>
52+
</redis>
53+
<dbal>
54+
<table_name>enqueue</table_name>
55+
<polling_interval>1000</polling_interval>
56+
<lazy>1</lazy>
57+
</dbal>
4058
</enqueue>
4159
</default>
4260
</config>

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /