From 895aec82c19af6d747a760b0244e01bef2d4ac2b Mon Sep 17 00:00:00 2001
From: azw <vcl_delphi@126.com>
Date: Fri, 14 Apr 2023 09:13:08 +0000
Subject: [PATCH] 1

---
 server/wsproxy/upstream.cc | 33 +++++++++++++++++++++------------
 1 file changed, 21 insertions(+), 12 deletions(-)

diff --git a/server/wsproxy/upstream.cc b/server/wsproxy/upstream.cc
index aee615d..efae6a5 100644
--- a/server/wsproxy/upstream.cc
+++ b/server/wsproxy/upstream.cc
@@ -6,6 +6,7 @@
 
 #include <f8/udplog.h>
 #include <f8/timer.h>
+#include <f8/msgqueue.h>
 
 #include "ss_proto.pb.h"
 #include "ss_msgid.pb.h"
@@ -165,12 +166,16 @@ void UpStream::on_connect(a8::TcpClient* sender)
                                    sender->remote_address,
                                    sender->remote_port
                                  });
-    #if 0
-    App::Instance()->AddIMMsg(IM_UpStreamConnect,
-                              a8::XParams()
-                              .SetSender(instance_id)
-                              );
-    #endif
+    f8::MsgQueue::Instance()->PostMsg
+        (
+         IM_UpStreamConnect,
+         a8::Args
+         (
+          {
+              instance_id
+          }
+          )
+         );
 }
 
 void UpStream::on_disconnect(a8::TcpClient* sender)
@@ -183,12 +188,16 @@ void UpStream::on_disconnect(a8::TcpClient* sender)
                                   sender->remote_address,
                                   sender->remote_port
                                  });
-    #if 0
-    App::Instance()->AddIMMsg(IM_UpStreamDisconnect,
-                              a8::XParams()
-                              .SetSender(instance_id)
-                              );
-    #endif
+    f8::MsgQueue::Instance()->PostMsg
+        (
+         IM_UpStreamDisconnect,
+         a8::Args
+         (
+          {
+              instance_id
+          }
+          )
+         );
 }
 
 void UpStream::on_socketread(a8::TcpClient* sender, char* buf, unsigned int len)