@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | { |
101 | 101 | $redis = $this->redis; |
102 | 102 | $that = $this; |
103 | - $this->redis->pipeline(function () use ($redis, $workerId, $that) { |
|
103 | + $this->redis->pipeline(function() use ($redis, $workerId, $that) { |
|
104 | 104 | $redis->sadd("workers", $workerId); |
105 | 105 | $that->workerStarted($workerId); |
106 | 106 | }); |
@@ -110,7 +110,7 @@ discard block |
||
110 | 110 | { |
111 | 111 | $redis = $this->redis; |
112 | 112 | $that = $this; |
113 | - $redis->pipeline(function () use ($redis, $workerId, $that) { |
|
113 | + $redis->pipeline(function() use ($redis, $workerId, $that) { |
|
114 | 114 | $redis->srem("workers", $workerId); |
115 | 115 | $redis->del($that->redisKeyForWorker($workerId)); |
116 | 116 | $redis->del($that->redisKeyForWorkerStartTime($workerId)); |
@@ -202,7 +202,7 @@ discard block |
||
202 | 202 | { |
203 | 203 | $redis = $this->redis; |
204 | 204 | $workerKey = $this->redisKeyForWorker($workerId); |
205 | - $this->redis->pipeline(function () use ($redis, $workerKey, $block) { |
|
205 | + $this->redis->pipeline(function() use ($redis, $workerKey, $block) { |
|
206 | 206 | $redis->del($workerKey); |
207 | 207 | $block(); |
208 | 208 | }); |