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-08-05 17:21:40 +08:00
parent 1ad8449a69
commit c1e8393705
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+6 -1
View File
@@ -124,7 +124,12 @@ class Kafka implements CustomProcess
$setting = $server->setting['worker_num']; $setting = $server->setting['worker_num'];
$server->sendMessage(new Message(new Struct($topic, $message)), random_int(0, $setting - 1)); /** @var KafkaProvider $container */
$container = Snowflake::getDi()->get(KafkaProvider::class);
$data = $container->getConsumer($topic);
if (!empty($data)) {
$server->sendMessage(new $data(new Struct($topic, $message)), random_int(0, $setting - 1));
}
} catch (Throwable $exception) { } catch (Throwable $exception) {
logger()->addError($exception, 'throwable'); logger()->addError($exception, 'throwable');
} }