BUGFIX: Pass named arguments to executeCommand (#35)

Fixes neos/flow-development-collection#1382
Flowpack · Sep 5, 2018 · 5e436ee · 5e436ee
1 parent 65fd0a5
commit 5e436ee
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Classes/Job/JobManager.php b/Classes/Job/JobManager.php
@@ -92,7 +92,7 @@ public function waitAndExecute($queueName, $timeout = null)
         $queueSettings = $this->queueManager->getQueueSettings($queueName);
         try {
             if (isset($queueSettings['executeIsolated']) && $queueSettings['executeIsolated'] === true) {
-                Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, [$queue->getName(), base64_encode(serialize($message))]);
+                Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, ['queue' => $queue->getName(), 'serializedMessage' => base64_encode(serialize($message))]);
             } else {
                 $this->executeJobForMessage($queue, $message);
             }

diff --git a/Classes/Queue/FakeQueue.php b/Classes/Queue/FakeQueue.php
@@ -76,7 +76,7 @@ public function submit($payload, array $options = [])
     {
         $messageId = Algorithms::generateUUID();
         $message = new Message($messageId, $payload);
-        $commandArguments = [$this->name, base64_encode(serialize($message))];
+        $commandArguments = ['queue' => $this->name, 'serializedMessage' => base64_encode(serialize($message))];
         if ($this->async) {
             if (!method_exists(Scripts::class, 'executeCommandAsync')) {
                 throw new \RuntimeException('The "async" flag is set, but the currently used Flow version doesn\'t support this (Flow 3.3+ is required)', 1469116604);