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

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-05-04 03:57:26 +08:00
parent 17393bb4a4
commit 9df9c52ce9
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+2 -1
View File
@@ -12,6 +12,7 @@ use RdKafka\KafkaConsumer;
use RdKafka\TopicConf; use RdKafka\TopicConf;
use Snowflake\Abstracts\Config; use Snowflake\Abstracts\Config;
use Snowflake\Exception\ConfigException; use Snowflake\Exception\ConfigException;
use Snowflake\Runtime;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine\Channel; use Swoole\Coroutine\Channel;
use Swoole\Coroutine\System; use Swoole\Coroutine\System;
@@ -56,7 +57,7 @@ class Kafka extends \Snowflake\Process\Process
*/ */
public function before(Process $process): void public function before(Process $process): void
{ {
$content = System::readFile(storage('runtime.php')); $content = System::readFile(storage(Runtime::CACHE_NAME));
$annotation = Snowflake::app()->getAnnotation(); $annotation = Snowflake::app()->getAnnotation();
$annotation->setLoader(unserialize($content)); $annotation->setLoader(unserialize($content));