as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-04-11 19:21:14 +08:00
parent 9353a5fe94
commit b3521a7ba9
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnPipeMessage.php
+2 -8
View File
@@ -66,16 +66,10 @@ class OnPipeMessage extends Callback
*/ */
private function onKafkaWorker(array $message) private function onKafkaWorker(array $message)
{ {
var_dump($message); [$topic, $rdMessage] = $message['body'];
// [$topic, $message] = $message['body'];
//
// call_user_func($message['handler'], new Struct($topic, $message));
return 'success'; call_user_func($message['handler'], new Struct($topic, $rdMessage[1]));
/** @var TaskContainer $container */
$container = Snowflake::app()->get('kafka-container');
$container->process($topic, new Struct($topic, $message));
return 'success'; return 'success';
} }