Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

More reasonable default broadcast queue size

This commit is contained in:
Scott Lyons 2012-01-30 07:33:37 -05:00
parent 9a621e95eb
commit a4a1381ff0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/transport/mongodb.py
View File

@ -97,7 +97,7 @@ class Channel(virtual.Channel):
col.ensure_index([("queue", 1)])
if "messages.broadcast" not in database.collection_names():
capsize = conninfo.capped_queue_size or 10000000
capsize = conninfo.capped_queue_size or 100000
database.create_collection("messages.broadcast", size=capsize, capped=True)
self.bcast = getattr(database, "messages.broadcast")