|
@@ -103,7 +103,7 @@ |
|
|
block discarded – undo |
|
103
|
103
|
} |
|
104
|
104
|
|
|
105
|
105
|
// check schedule |
|
106
|
|
- $messagesString = $this->redis->zRangeByScore($this->scheduleKey, '-inf', (string)microtime(true), ['limit' => [0, 1]]); |
|
|
106
|
+ $messagesString = $this->redis->zRangeByScore($this->scheduleKey, '-inf', (string) microtime(true), ['limit' => [0, 1]]); |
|
107
|
107
|
if (count($messagesString)) { |
|
108
|
108
|
foreach ($messagesString as $messageString) { |
|
109
|
109
|
$this->redis->zRem($this->scheduleKey, $messageString); |
Please login to merge, or discard this patch.