改名

2020-10-09 17:13:37 +08:00
parent 916d6f1ae0
commit de157e0d69
1 changed files with 1 additions and 1 deletions
@@ -40,7 +40,7 @@ class Kafka extends \Snowflake\Process\Process
 				if (!class_exists($namespace)) {
 					return;
 				}
-				$class = new $namespace();
+				$class = Snowflake::createObject($namespace);
 				if ($class instanceof ConsumerInterface) {
 					$class->onHandler(
 						$message['offset'],