Skip to content

Commit 5e436ee

Browse files
kdambekalnsBastian Waidelich
authored andcommitted
BUGFIX: Pass named arguments to executeCommand (#35)
Fixes neos/flow-development-collection#1382
1 parent 65fd0a5 commit 5e436ee

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Classes/Job/JobManager.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ public function waitAndExecute($queueName, $timeout = null)
9292
$queueSettings = $this->queueManager->getQueueSettings($queueName);
9393
try {
9494
if (isset($queueSettings['executeIsolated']) && $queueSettings['executeIsolated'] === true) {
95-
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, [$queue->getName(), base64_encode(serialize($message))]);
95+
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, ['queue' => $queue->getName(), 'serializedMessage' => base64_encode(serialize($message))]);
9696
} else {
9797
$this->executeJobForMessage($queue, $message);
9898
}

Classes/Queue/FakeQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public function submit($payload, array $options = [])
7676
{
7777
$messageId = Algorithms::generateUUID();
7878
$message = new Message($messageId, $payload);
79-
$commandArguments = [$this->name, base64_encode(serialize($message))];
79+
$commandArguments = ['queue' => $this->name, 'serializedMessage' => base64_encode(serialize($message))];
8080
if ($this->async) {
8181
if (!method_exists(Scripts::class, 'executeCommandAsync')) {
8282
throw new \RuntimeException('The "async" flag is set, but the currently used Flow version doesn\'t support this (Flow 3.3+ is required)', 1469116604);

0 commit comments

Comments
 (0)