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;
-
-
 }