as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-03-29 15:05:35 +08:00
parent bd57493d1a
commit b1b42e053d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Crontab/ZookeeperProcess.php
+1 -1
View File
@@ -58,6 +58,7 @@ class ZookeeperProcess extends Process
$range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
$redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
$redis->release();
/** @var Consumer $consumer */ /** @var Consumer $consumer */
$consumer = Snowflake::app()->get(Consumer::class); $consumer = Snowflake::app()->get(Consumer::class);
@@ -65,7 +66,6 @@ class ZookeeperProcess extends Process
foreach ($range as $value) { foreach ($range as $value) {
$consumer->write('crontab:' . md5($value)); $consumer->write('crontab:' . md5($value));
} }
$redis->release();
}); });
} }