diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index add0e975..4fcde242 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -68,7 +68,7 @@ class OnPipeMessage extends Callback { [$topic, $rdMessage] = $message['body']; - call_user_func($message['handler'], new Struct($topic, $rdMessage[1])); + call_user_func($message['handler'], new Struct($topic, $rdMessage)); return 'success'; }