1

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} 已结束。。。')