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 16:26:51 +08:00
parent 64df33b1f2
commit 6f9d48f779
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+4 -3
View File
@@ -127,14 +127,15 @@ class Kafka implements CustomProcess
$setting = $server->setting['worker_num']; $setting = $server->setting['worker_num'];
/** @var KafkaProvider $container */
$container = Snowflake::app()->get('kafka-container'); $container = Snowflake::app()->get('kafka-container');
$handler = $container->getConsumer($topic); $handler = $container->getConsumer($topic);
if (!empty($handler)) { if (!empty($handler)) {
$data = new Struct($topic, $message); /** @var ConsumerInterface $data */
$data = new $handler();
$data->setParams(new Struct($topic, $message));
$server->sendMessage(new $handler($data), random_int(0, $setting - 1)); $server->sendMessage($data, random_int(0, $setting - 1));
} }
} catch (Throwable $exception) { } catch (Throwable $exception) {
logger()->addError($exception, 'throwable'); logger()->addError($exception, 'throwable');