Forgot to commit transaction

kombu/transport/django/managers.py

@@ -57,12 +57,12 @@ class MessageManager(models.Manager):
             result.save()
             recv = self.__class__._messages_received
             recv[0] += 1
+            transaction.commit()
             if not recv[0] % self.cleanup_every:
                 self.cleanup()
-            transaction.commit()
             return result.payload
         except self.model.DoesNotExist:
-            pass
+            transaction.commit()
         except:
             transaction.rollback()