From 9df9c52ce9abf025756642d6159d74eca1eeafec Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Tue, 4 May 2021 03:57:26 +0800 Subject: [PATCH] modify --- Kafka/Kafka.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 17afb847..45953d23 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -12,6 +12,7 @@ use RdKafka\KafkaConsumer; use RdKafka\TopicConf; use Snowflake\Abstracts\Config; use Snowflake\Exception\ConfigException; +use Snowflake\Runtime; use Snowflake\Snowflake; use Swoole\Coroutine\Channel; use Swoole\Coroutine\System; @@ -56,7 +57,7 @@ class Kafka extends \Snowflake\Process\Process */ public function before(Process $process): void { - $content = System::readFile(storage('runtime.php')); + $content = System::readFile(storage(Runtime::CACHE_NAME)); $annotation = Snowflake::app()->getAnnotation(); $annotation->setLoader(unserialize($content));