From 648385b64a8cbeb1251b0a7454ec4f001edd7bdd Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Thu, 8 Apr 2021 02:25:18 +0800
Subject: [PATCH] modify

---
 HttpServer/Events/OnPipeMessage.php | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php
index 1633ca41..6627c42e 100644
--- a/HttpServer/Events/OnPipeMessage.php
+++ b/HttpServer/Events/OnPipeMessage.php
@@ -28,16 +28,8 @@ class OnPipeMessage extends Callback
      */
     public function onHandler(Server $server, int $src_worker_id, $message)
     {
-        if ($message instanceof Loader) {
-            if ($src_worker_id > $server->setting['worker_num']) {
-                $message->loadByDirectory(MODEL_PATH);
-            } else {
-                $message->loadByDirectory(APP_PATH);
-            }
-        } else {
-            $events = Snowflake::app()->getEvent();
-            $events->trigger(Event::PIPE_MESSAGE, [$server, $src_worker_id, $message]);
-        }
+        $events = Snowflake::app()->getEvent();
+        $events->trigger(Event::PIPE_MESSAGE, [$server, $src_worker_id, $message]);
     }
 
 }