modify

2021-04-11 19:10:37 +08:00
parent d24558233e
commit a940719c13
1 changed files with 4 additions and 3 deletions
@@ -66,9 +66,10 @@ class OnPipeMessage extends Callback
     */
    private function onKafkaWorker(array $message)
    {
-        [$topic, $message] = $message['body'];
+        var_dump($message);
-
+//        [$topic, $message] = $message['body'];
-        call_user_func($message['handler'], new Struct($topic, $message));
+//
 //        call_user_func($message['handler'], new Struct($topic, $message));
        return 'success';