Revision e88c731ade270a7d37b8a7c758af40aca69991a8 authored by Nicolas Dandrimont on 22 February 2016, 14:07:52 UTC, committed by Nicolas Dandrimont on 22 February 2016, 14:07:52 UTC
We reimplement the event listener using kombu directly instead of Celery, which allows us to create persistent queues and manually ack the messages once we have received them. We bundle messages by packets of 1000 or 1/second when sending them to the database. We only ack the messages once the database transcation has ended.
1 parent c4e1b63
| File | Mode | Size |
|---|---|---|
| debian | ||
| sql | ||
| swh | ||
| .gitignore | -rw-r--r-- | 67 bytes |
| AUTHORS | -rw-r--r-- | 112 bytes |
| LICENSE | -rw-r--r-- | 34.3 KB |
| MANIFEST.in | -rw-r--r-- | 62 bytes |
| Makefile | -rw-r--r-- | 163 bytes |
| requirements.txt | -rw-r--r-- | 255 bytes |
| setup.py | -rw-r--r-- | 821 bytes |
Computing file changes ...
