brainexe / core

src/MessageQueue/Gateway.php

Spacing +3 added lines, -3 removed lines

@@ -79,7 +79,7 @@ 
         $pipeline = $this->getRedis()->pipeline(['fire-and-forget' => true]);
         if (empty($job->timestamp)) {
             // immediate execution in background
-            $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId . '#' . $serialized);
+            $pipeline->lpush(self::QUEUE_IMMEDIATE, $job->jobId.'#'.$serialized);
         } else {
             // delayed execution
             $pipeline->hset(self::META_DATA, $job->jobId, $serialized);
@@ -119,7 +119,7 @@ 
 
         $keys = [];
         foreach ($resultRaw as $jobId => $timestamp) {
-            if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) {
+            if (empty($eventType) || strpos($jobId, $eventType.":") === 0) {
                 $keys[$jobId] = $timestamp;
             }
         }
@@ -176,7 +176,7 @@ 
         $immediate = $this->getRedis()->lrange(self::QUEUE_IMMEDIATE, 0, 100);
         foreach ($immediate as $rawJob) {
             list($jobId, $rawJob) = explode('#', $rawJob, 2);
-            if (empty($eventType) || strpos($jobId, $eventType . ":") === 0) {
+            if (empty($eventType) || strpos($jobId, $eventType.":") === 0) {
                 /** @var Job $job */
                 $job = unserialize(base64_decode($rawJob));
                 yield $job->jobId => $job;