From 15591fd7ae2e096f6952e56db69bc686f23965da Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Fri, 17 Sep 2021 18:11:56 +0800
Subject: [PATCH] 1

---
 app.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/app.py b/app.py
index 16a5f91..61d8feb 100644
--- a/app.py
+++ b/app.py
@@ -52,6 +52,7 @@ class XProcess(Process):
                 obj = getattr(handler_event, type_)
                 obj(msg)
             elif type_ == settings.STOP_SIGNAL:
+                continue
                 # 1 小时内有效
                 if msg.get('#time', 0) + 3600 < int(time.time()):
                     continue
@@ -71,4 +72,4 @@ class XProcess(Process):
 
         while True:
             time.sleep(5)
-            print(f'进程{self.partition} 已结束。。。')
+            print(f'消费分区{self.partition} 已结束。。。')