This commit is contained in:
2021-08-05 17:27:08 +08:00
parent efe5a71124
commit 9ee9008019
2 changed files with 4 additions and 5 deletions
-1
View File
@@ -127,7 +127,6 @@ class Kafka implements CustomProcess
/** @var KafkaProvider $container */
$container = Snowflake::getDi()->get(KafkaProvider::class);
$data = $container->getConsumer($topic);
var_dump($data);
if (!empty($data)) {
$server->sendMessage(new $data(new Struct($topic, $message)), random_int(0, $setting - 1));
}
+4 -4
View File
@@ -135,11 +135,11 @@ class Container extends BaseObject
if ($construct->getNumberOfParameters() < 1) {
return $reflect->newInstance();
}
$parameters = $this->resolveMethodParameters($construct);
if (!empty($dependencies)) {
$parameters = $this->mergeParam($parameters, $dependencies);
if (empty($dependencies)) {
return $reflect->newInstanceWithoutConstructor();
}
$parameters = $this->resolveMethodParameters($construct);
$parameters = $this->mergeParam($parameters, $dependencies);
return $reflect->newInstanceArgs($parameters);
}