SQS: batch mode always consumes messages. Closes celery/celery#1818

1 files changed, 1 insertions, 7 deletions

diff --git a/kombu/transport/virtual/__init__.py b/kombu/transport/virtual/__init__.py
index 459d55b1..c05e65d1 100644
--- a/kombu/transport/virtual/__init__.py
+++ b/kombu/transport/virtual/__init__.py
@@ -142,14 +142,8 @@ class QoS(object):
             An integer > 0
         """
         pcount = self.prefetch_count
-        count = None
         if pcount:
-            count = pcount - (len(self._delivered) - len(self._dirty))
-
-        if count < 1:
-            return 1
-
-        return count
+            return max(pcount - (len(self._delivered) - len(self._dirty), 0)
 
     def append(self, message, delivery_tag):
         """Append message to transactional state."""