From 52c49f7854015f4c9c55a81fcd9ba2b31b88ac56 Mon Sep 17 00:00:00 2001
From: "Flavio [FlaPer87] Percoco Premoli" <flaper87@flaper87.org>
Date: Tue, 6 Dec 2011 11:04:33 +0100
Subject: [PATCH] Using queue as filter transport.mongodb

---
 kombu/transport/mongodb.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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