Commit 9328305

committed

magento enqueue

1 parent 2be6ba9 commit 9328305Copy full SHA for 9328305

File tree

+11

-10

lines changed

+11

-10

lines changed

Lines changed: 0 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -3,8 +3,6 @@`
`3`	`3`	`"type": "magento-module",`
`4`	`4`	`"description": "Enqueue Message Queue for Magento",`
`5`	`5`	`"require": {`
`6`		`- "enqueue/amqp-ext": "^0.3",`
`7`		`- "enqueue/dbal": "^0.3",`
`8`	`6`	`"enqueue/enqueue": "^0.3",`
`9`	`7`	`"enqueue/simple-client": "^0.3"`
`10`	`8`	`},`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@`
`24`	`24`	`$enqueue = Mage::helper('enqueue');`
`25`	`25`	`$enqueue->bindProcessors();`
`26`	`26`
`27`		`-/** @var \Enqueue\Client\SimpleClient $client */`
	`27`	`+/** @var \Enqueue\SimpleClient\SimpleClient $client */`
`28`	`28`	`$client = $enqueue->getClient();`
`29`	`29`
`30`	`30`	`$application = new Application();`
`@@ -34,7 +34,7 @@`
`34`	`34`	`$application->add(new TopicsCommand($client->getTopicMetaRegistry()));`
`35`	`35`	`$application->add(new ConsumeMessagesCommand(`
`36`	`36`	`$client->getQueueConsumer(),`
`37`		`- $client->getProcessor(),`
	`37`	`+ $client->getDelegateProcessor(),`
`38`	`38`	`$client->getQueueMetaRegistry(),`
`39`	`39`	`$client->getDriver()`
`40`	`40`	`));`

Lines changed: 7 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,8 @@`
`1`	`1`	`<?php`
`2`	`2`
`3`	`3`	`use Enqueue\Client\Message;`
`4`		`-use Enqueue\Client\SimpleClient;`
`5`	`4`	`use Enqueue\Psr\PsrProcessor;`
	`5`	`+use Enqueue\SimpleClient\SimpleClient;`
`6`	`6`
`7`	`7`	`class Enqueue_Enqueue_Helper_Data extends Mage_Core_Helper_Data`
`8`	`8`	`{`
`@@ -232,10 +232,12 @@ public function getRedisConfig()`
`232`	`232`	`public function getDbalConfig()`
`233`	`233`	`{`
`234`	`234`	`return ['dbal' => [`
`235`		`- 'url' => Mage::getStoreConfig('enqueue/redis/url'),`
`236`		`- 'table_name' => Mage::getStoreConfig('enqueue/redis/table_name'),`
`237`		`- 'polling_interval' => (int) Mage::getStoreConfig('enqueue/redis/polling_interval'),`
`238`		`- 'lazy' => (bool) Mage::getStoreConfig('enqueue/redis/lazy'),`
	`235`	`+ 'connection' => [`
	`236`	`+ 'url' => Mage::getStoreConfig('enqueue/dbal/url'),`
	`237`	`+ ],`
	`238`	`+ 'table_name' => Mage::getStoreConfig('enqueue/dbal/table_name'),`
	`239`	`+ 'polling_interval' => (int) Mage::getStoreConfig('enqueue/dbal/polling_interval'),`
	`240`	`+ 'lazy' => (bool) Mage::getStoreConfig('enqueue/dbal/lazy'),`
`239`	`241`	`]];`
`240`	`242`	`}`
`241`	`243`	`}`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -388,6 +388,7 @@`
`388`	`388`	`<show_in_default>1</show_in_default>`
`389`	`389`	`<show_in_website>0</show_in_website>`
`390`	`390`	`<show_in_store>0</show_in_store>`
	`391`	`+ <comment><![CDATA[<strong style="color:orange">Note!</strong> <strong>Client:Router Topic</strong> and <strong>Client:Router Queue</strong> must be equal for this transport.]]></comment>`
`391`	`392`	`<fields>`
`392`	`393`	`<store_dir translate="label">`
`393`	`394`	`<label>Store directory</label>`
`@@ -546,7 +547,7 @@`
`546`	`547`	`<show_in_default>1</show_in_default>`
`547`	`548`	`<show_in_website>0</show_in_website>`
`548`	`549`	`<show_in_store>-</show_in_store>`
`549`		`- <comment><![CDATA[<a target="_blank" href="http://docs.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#connecting-using-a-url">Connecting using a URL</a>]]></comment>`
	`550`	`+ <comment><![CDATA[<a target="_blank" href="http://docs.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#connecting-using-a-url">Connecting using a URL</a> Example: mysql://user:password@host:port/dbname?charset=UTF8]]></comment>`
`550`	`551`	`</url>`
`551`	`552`	`<table_name translate="label">`
`552`	`553`	`<label>Table name</label>`

Comments

(0)