View GitHub Repository resque

Schedule Inspection
Subscribe
Test Failed
Retried Inspection
Branch — master (943012)
by Dirk
03:57
created
Category
Toggle Patches
src/DataStore.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch 
@@ -25,7 +25,7 @@  discard block
 
 block discarded – undo
25 25 
     {
26 26 
         return array_map(
27 27 
             $this->redis->keys('*'),
28 
-            function ($key) {
28 
+            function($key) {
29 29 
                 return str_replace("{$this->namespace}:", '');
30 30 
             }
31 31 
         );
 
@@ -35,7 +35,7 @@  discard block
 
 block discarded – undo
35 35 
     {
36 36 
         $redis = $this->redis;
37 37 
         $queueKey = $this->redisKeyForQueue($queueName);
38 
-        $this->redis->pipeline(function () use ($redis, $queueKey, $json) {
38 
+        $this->redis->pipeline(function() use ($redis, $queueKey, $json) {
39 39 
             $redis->sadd('queues', $queueName);
40 40 
             $redis->rpush($queueKey, $json);
41 41 
         });
 
@@ -75,7 +75,7 @@  discard block
 
 block discarded – undo
75 75 
     {
76 76 
         $redis = $this->redis;
77 77 
         $that = $this;
78 
-        $this->redis->pipeline(function () use ($redis, $workerId, $that) {
78 
+        $this->redis->pipeline(function() use ($redis, $workerId, $that) {
79 79 
             $redis->sadd("workers", $workerId);
80 80 
             $that->workerStarted($workerId);
81 81 
         });
 
@@ -85,7 +85,7 @@  discard block
 
 block discarded – undo
85 85 
     {
86 86 
         $redis = $this->redis;
87 87 
         $that = $this;
88 
-        $redis->pipeline(function () use ($redis, $workerId, $that) {
88 
+        $redis->pipeline(function() use ($redis, $workerId, $that) {
89 89 
             $redis->srem("workers", $workerId);
90 90 
             $redis->del($that->redisKeyForWorker($workerId));
91 91 
             $redis->del($that->redisKeyForWorkerStartTime($workerId));
 
@@ -167,7 +167,7 @@  discard block
 
 block discarded – undo
167 167 
     {
168 168 
         $redis = $this->redis;
169 169 
         $workerKey = $this->redisKeyForWorker($workerId);
170 
-        $this->redis->pipeline(function () use ($redis, $workerKey, $block) {
170 
+        $this->redis->pipeline(function() use ($redis, $workerKey, $block) {
171 171 
             $redis->del($workerKey);
172 172 
             $block();
173 173 
         });
Please login to merge, or discard this patch.