From dd5e65b52267b3c31d48ca1d6d66f0ff5a7577d5 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sat, 24 Apr 2021 20:46:17 +0800 Subject: [PATCH] modify --- HttpServer/Events/OnPipeMessage.php | 4 +--- Kafka/ConsumerInterface.php | 3 --- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index 1da51981..61de1d6e 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -92,9 +92,7 @@ class OnPipeMessage extends Callback { [$topic, $rdMessage] = $message['body']; - $message['handler'][0]->setParams(new Struct($topic, $rdMessage)); - - call_user_func($message['handler']); + call_user_func($message['handler'], new Struct($topic, $rdMessage)); return 'success'; } diff --git a/Kafka/ConsumerInterface.php b/Kafka/ConsumerInterface.php index 707db7f9..e530c7db 100644 --- a/Kafka/ConsumerInterface.php +++ b/Kafka/ConsumerInterface.php @@ -19,7 +19,4 @@ interface ConsumerInterface public function onHandler(Struct $struct): void; - public function setParams(...$params): void; - - }