From a940719c13a7aa6e0257ead2410af9bca3c4517d Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Sun, 11 Apr 2021 19:10:37 +0800
Subject: [PATCH] modify

---
 HttpServer/Events/OnPipeMessage.php | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php
index 44ea20e0..31b13fa1 100644
--- a/HttpServer/Events/OnPipeMessage.php
+++ b/HttpServer/Events/OnPipeMessage.php
@@ -66,9 +66,10 @@ class OnPipeMessage extends Callback
      */
     private function onKafkaWorker(array $message)
     {
-        [$topic, $message] = $message['body'];
-
-        call_user_func($message['handler'], new Struct($topic, $message));
+        var_dump($message);
+//        [$topic, $message] = $message['body'];
+//
+//        call_user_func($message['handler'], new Struct($topic, $message));
 
         return 'success';