update deps. make it work with enqueue 0.7

formapro · Aug 16, 2017 · bdcab50 · bdcab50
1 parent 83f4734
commit bdcab50
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/composer.json b/composer.json
@@ -20,11 +20,11 @@
         "php": "^7",
         "makasim/values": "@dev",
         "symfony/console": "^3.1",
-        "graphp/graphviz": "^0.2.1",
         "ramsey/uuid": "^3"
     },
     "suggest": {
-        "enqueue/enqueue": "Install the Enqueue library to be able to process tasks async (by using MQ).",
+        "enqueue/enqueue": "^0.7 Install the Enqueue library to be able to process tasks async (by using MQ).",
+        "graphp/graphviz": "^0.2 If you want to visualize graphs",
         "makasim/yadm": "Install the Yadm library to be able to persist store in MongoDB"
     },
     "extra": {

diff --git a/docs/parallel-execution-with-enqueue.md b/docs/parallel-execution-with-enqueue.md
@@ -98,8 +98,8 @@ use Formapro\Pvm\ProcessEngine;
 use Formapro\Pvm\ProcessStorage;
 use Enqueue\SimpleClient\SimpleClient;
 use Formapro\Pvm\Enqueue\HandleAsyncTransitionProcessor;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrContext;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrContext;
 use Enqueue\Client\Config;
 
 include __DIR__.'/config.php';

diff --git a/src/Enqueue/AsyncTransition.php b/src/Enqueue/AsyncTransition.php
@@ -27,7 +27,7 @@ public function transition(array $tokens)
         foreach ($tokens as $token) {
             /** @var Token $token */
 
-            $this->producer->send(HandleAsyncTransitionProcessor::TOPIC, [
+            $this->producer->sendCommand(HandleAsyncTransitionProcessor::COMMAND, [
                 'process' => $token->getProcess()->getId(),
                 'token' => $token->getId(),
             ]);

diff --git a/src/Enqueue/HandleAsyncTransitionProcessor.php b/src/Enqueue/HandleAsyncTransitionProcessor.php
@@ -4,9 +4,9 @@
 use Enqueue\Client\CommandSubscriberInterface;
 use Enqueue\Consumption\QueueSubscriberInterface;
 use Enqueue\Consumption\Result;
-use Enqueue\Psr\PsrContext;
-use Enqueue\Psr\PsrMessage;
-use Enqueue\Psr\PsrProcessor;
+use Interop\Queue\PsrContext;
+use Interop\Queue\PsrMessage;
+use Interop\Queue\PsrProcessor;
 use Enqueue\Util\JSON;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\ProcessEngine;