@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | $pipeline = $this->getRedis()->pipeline(['fire-and-forget' => true]); |
80 | 80 | if (empty($job->timestamp)) { |
81 | 81 | // immediate execution in background |
82 | - $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId . '#' . $serialized); |
|
82 | + $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId.'#'.$serialized); |
|
83 | 83 | } else { |
84 | 84 | // delayed execution |
85 | 85 | $pipeline->hset(self::META_DATA, $job->jobId, $serialized); |
@@ -119,7 +119,7 @@ discard block |
||
119 | 119 | |
120 | 120 | $keys = []; |
121 | 121 | foreach ($resultRaw as $jobId => $timestamp) { |
122 | - if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) { |
|
122 | + if (empty($eventType) || strpos($jobId, $eventType.":") === 0) { |
|
123 | 123 | $keys[$jobId] = $timestamp; |
124 | 124 | } |
125 | 125 | } |
@@ -176,7 +176,7 @@ discard block |
||
176 | 176 | $immediate = $this->getRedis()->lrange(self::QUEUE_IMMEDIATE, 0, 100); |
177 | 177 | foreach ($immediate as $rawJob) { |
178 | 178 | list($jobId, $rawJob) = explode('#', $rawJob, 2); |
179 | - if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) { |
|
179 | + if (empty($eventType) || strpos($jobId, $eventType.":") === 0) { |
|
180 | 180 | /** @var Job $job */ |
181 | 181 | $job = unserialize(base64_decode($rawJob)); |
182 | 182 | yield $job->jobId => $job; |