message checking callbacks only need to run 10 times a second

This commit is contained in:
Vishvananda Ishaya
2010-06-24 04:12:00 +01:00
committed by andy
parent a7e16dd994
commit 2006b4b4e5

View File

@@ -68,7 +68,7 @@ class Consumer(messaging.Consumer):
io_inst = ioloop.IOLoop.instance()
injected = ioloop.PeriodicCallback(
lambda: self.fetch(enable_callbacks=True), 1, io_loop=io_inst)
lambda: self.fetch(enable_callbacks=True), 100, io_loop=io_inst)
injected.start()
return injected
@@ -80,7 +80,7 @@ class Consumer(messaging.Consumer):
def attach_to_twisted(self):
loop = task.LoopingCall(self.fetch, enable_callbacks=True)
loop.start(interval=0.01)
loop.start(interval=0.1)
class Publisher(messaging.Publisher):
pass