diff options
| author | Flavio [FlaPer87] Percoco Premoli <flaper87@flaper87.org> | 2011-12-06 11:04:33 +0100 |
|---|---|---|
| committer | Flavio [FlaPer87] Percoco Premoli <flaper87@flaper87.org> | 2011-12-06 11:04:33 +0100 |
| commit | 52c49f7854015f4c9c55a81fcd9ba2b31b88ac56 (patch) | |
| tree | d7ff8b139a266d5a43e9a174b63e88bc6becda48 /kombu/transport/mongodb.py | |
| parent | 5b3c793dfb78cce52f7f958b81273fb4ca3ebd6a (diff) | |
| download | kombu-52c49f7854015f4c9c55a81fcd9ba2b31b88ac56.tar.gz | |
Using queue as filter transport.mongodb
Diffstat (limited to 'kombu/transport/mongodb.py')
| -rw-r--r-- | kombu/transport/mongodb.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/transport/mongodb.py b/kombu/transport/mongodb.py index 8fcb273d..ee08d40e 100644 --- a/kombu/transport/mongodb.py +++ b/kombu/transport/mongodb.py @@ -46,7 +46,7 @@ class Channel(virtual.Channel): return deserialize(msg["value"]["payload"]) def _size(self, queue): - return self.client.count() + return self.client.find({"queue": queue}).count() def _put(self, queue, message, **kwargs): self.client.insert({"payload": serialize(message), "queue": queue}) |