Improve event processing speed by sending to the server in bulk

2012-11-09 13:11:39 -05:00
parent d01075e094
commit a5044e49c7
1 changed files with 2 additions and 1 deletions
--- a/api/handlers.py
+++ b/api/handlers.py
@@ -93,9 +93,10 @@ class ServerEventHandler(BaseHandler):
        queue.watch('caminus-broadcast-%s'%request.server.id)
        events = []
        job = queue.reserve(timeout=30)
-        if job:
+        while job:
          job.bury()
          events.append({'id': job.jid, 'event': json.loads(job.body)})
+          job = queue.reserve(timeout=0)
        return {'events': events}

    def create(self, request):