File tree Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,8 @@ composer require "magento-hackathon/magento-composer-installer:~3.0"
14
14
composer require " enqueue/magento-enqueue:*@dev" " enqueue/amqp-ext"
15
15
```
16
16
17
+ _ ** Note** : You could use not only AMQP transport but any other [ available] ( ../transport ) ._
18
+
17
19
## Configuration
18
20
19
21
At this stage we have configure the Enqueue extension in Magento backend.
Original file line number Diff line number Diff line change @@ -34,7 +34,12 @@ To send a message you have to take enqueue helper and call `send` method.
34
34
35
35
$objectManager = \Magento\Framework\App\ObjectManager::getInstance();
36
36
$enqueueManager = $objectManager->create('Enqueue\Enqueue\Model\EnqueueManager');
37
- $enqueueManager->send('a_topic', 'aMessage');
37
+ $enqueueManager->sendEvent('a_topic', 'aMessage');
38
+
39
+ // or a command with a possible reply
40
+ $reply = $enqueueManager->sendCommand('a_topic', 'aMessage', true);
41
+
42
+ $replyMessage = $reply->receive(5000); // wait for 5 sec
38
43
```
39
44
40
45
## Message Consumption
You can’t perform that action at this time.
0 commit comments