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

Using queue as filter transport.mongodb

This commit is contained in:
Flavio [FlaPer87] Percoco Premoli 2011-12-06 11:04:33 +01:00
parent 5b3c793dfb
commit 52c49f7854
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

@ -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})