diff --git a/single_process.py b/single_process.py index 32b47ff..bd081b4 100644 --- a/single_process.py +++ b/single_process.py @@ -31,9 +31,9 @@ def run(): for topic, msg in consumer(): # print(msg) type_ = msg['#type'] - if msg['#event_name'] != 'pay': - continue - print(msg) + # if msg['#event_name'] != 'pay': + # continue + # print(msg) del msg['#type'] ts = int(time.time())