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-02-24 14:11:32 +08:00
parent 40bc96c2c7
commit c82e90ae87
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+2 -5
View File
@@ -111,14 +111,11 @@ class Kafka extends \Snowflake\Process\Process
if (!class_exists($namespace)) { if (!class_exists($namespace)) {
return; return;
} }
$class = objectPool($namespace); $class = Snowflake::createObject($namespace);
if (!($class instanceof ConsumerInterface)) { if (!($class instanceof ConsumerInterface)) {
return; return;
} }
$class->onHandler($Struct = objectPool(Struct::class, [$topic, $message])); $class->onHandler(Snowflake::createObject(Struct::class, [$topic, $message]));
objectRecover($namespace, $class);
objectRecover(Struct::class, $Struct);
} catch (Throwable $exception) { } catch (Throwable $exception) {
$this->application->error($exception); $this->application->error($exception);
} }