Skip to content

Commit 5287b4d

Browse files
kdambekalnsBastian Waidelich
authored andcommitted
BUGFIX: Pass named arguments to executeCommand (#37)
Fixes neos/flow-development-collection#1382
1 parent 6d7bf4c commit 5287b4d

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

Classes/Job/JobManager.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public function waitAndExecute(string $queueName, $timeout = null): ?Message
103103
if (isset($queueSettings['executeIsolated']) && $queueSettings['executeIsolated'] === true) {
104104
$messageCacheIdentifier = sha1(serialize($message));
105105
$this->messageCache->set($messageCacheIdentifier, $message);
106-
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, [$queue->getName(), $messageCacheIdentifier]);
106+
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, false, ['queue' => $queue->getName(), 'messageCacheIdentifier' => $messageCacheIdentifier]);
107107
} else {
108108
$this->executeJobForMessage($queue, $message);
109109
}

Classes/Queue/FakeQueue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,9 +88,9 @@ public function submit($payload, array $options = []): string
8888
$this->messageCache->set($messageCacheIdentifier, $message);
8989

9090
if ($this->async) {
91-
Scripts::executeCommandAsync('flowpack.jobqueue.common:job:execute', $this->flowSettings, [$this->name, $messageCacheIdentifier]);
91+
Scripts::executeCommandAsync('flowpack.jobqueue.common:job:execute', $this->flowSettings, ['queue' => $this->name, 'messageCacheIdentifier' => $messageCacheIdentifier]);
9292
} else {
93-
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, true, [$this->name, $messageCacheIdentifier]);
93+
Scripts::executeCommand('flowpack.jobqueue.common:job:execute', $this->flowSettings, true, ['queue' => $this->name, 'messageCacheIdentifier' => $messageCacheIdentifier]);
9494
}
9595
return $messageId;
9696
}

0 commit comments

Comments
 (0)