改名

2021-02-23 17:43:13 +08:00
parent 29fc384741
commit 1c0cd04fcc
6 changed files with 37 additions and 14 deletions
@@ -115,7 +115,10 @@ class Kafka extends \Snowflake\Process\Process
 				if (!($class instanceof ConsumerInterface)) {
 					return;
 				}
-				$class->onHandler(objectPool(Struct::class, [$topic, $message]));
+				$class->onHandler($Struct = objectPool(Struct::class, [$topic, $message]));
+
+				objectRecover($namespace, $class);
+				objectRecover(Struct::class, $Struct);
 			} catch (Throwable $exception) {
 				$this->application->error($exception);
 			}