测试消费

This commit is contained in:
wuaho 2021-09-18 10:19:34 +08:00
parent 4a670de26b
commit 7fb03eb90c

2
app.py
View File

@ -66,6 +66,8 @@ class XProcess(Process):
self.log.info(f'进程{self.partition} 结束')
break
elif type_ == 'test':
self.log.info(f'消费分区{self.partition} -> {msg}')
else:
continue