From eef92b3fdcbccf4ace75132791dae28ab12c9e02 Mon Sep 17 00:00:00 2001 From: wuaho Date: Sat, 14 Aug 2021 11:15:12 +0800 Subject: [PATCH] 1 --- app.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/app.py b/app.py index 8640f52..e58ee45 100644 --- a/app.py +++ b/app.py @@ -26,8 +26,10 @@ class XProcess(Process): handler_user = HandlerUser(db_client, settings.GAME) transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr, self.partition) + transmitter.start_ping() transmitter.add_source(handler_event, 5000, 60) transmitter.add_source(handler_user, 500, 60) + last_ts = int(time.time()) consumer, kafka_client = create_consumer(self.partition)