diff --git a/app.py b/app.py index e803e22..ea077f4 100644 --- a/app.py +++ b/app.py @@ -23,8 +23,8 @@ class XProcess(Process): handler_event = HandlerEvent(db_client, settings.GAME, self.ipsearch) handler_user = HandlerUser(db_client, settings.GAME) transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr) - transmitter.add_source(handler_event, 10000, 60) - transmitter.add_source(handler_user, 1000, 60) + transmitter.add_source(handler_event, 2000, 60) + transmitter.add_source(handler_user, 500, 60) last_ts = int(time.time()) consumer = create_consumer(self.partition)