diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-02-03 17:21:13 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-02-03 17:21:13 +0000 |
| commit | cfea2062b060c32cc035e3f025e5b96805738bd9 (patch) | |
| tree | 1682159c2caa1209d443b6c0d8a963cbbf91a03e | |
| parent | d1cbcef94cca5ed3bef92a2ac708759dac35f9f6 (diff) | |
| download | kombu-cfea2062b060c32cc035e3f025e5b96805738bd9.tar.gz | |
BrokerConnection does not have capped_queue_size attribute
| -rw-r--r-- | kombu/transport/mongodb.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index d924e465..367068a0 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -112,7 +112,8 @@ class Channel(virtual.Channel): col.ensure_index([("queue", 1)]) if "messages.broadcast" not in database.collection_names(): - capsize = conninfo.capped_queue_size or 100000 + capsize = conninfo.transport_options.get( + "capped_queue_size") or 100000 database.create_collection("messages.broadcast", size=capsize, capped=True) |