Now requires carrot 0.4.0 (master from github), and auto_ack is on for the

task consumer.

celery/messaging.py

@@ -71,3 +71,4 @@ class TaskConsumer(NoProcessConsumer):
     exchange = conf.AMQP_EXCHANGE
     routing_key = conf.AMQP_CONSUMER_ROUTING_KEY
     exchange_type = conf.AMQP_EXCHANGE_TYPE
+    auto_ack = True

celery/worker.py

@@ -123,7 +123,6 @@ class TaskWrapper(object):
         args = message_data["args"]
         kwargs = message_data["kwargs"]
         if task_name not in tasks:
-            message.reject()
             raise UnknownTask(task_name)
         task_func = tasks[task_name]
         return cls(task_name, task_id, task_func, args, kwargs)
@@ -284,7 +283,6 @@ class WorkController(object):
         if message is not None:
             self.logger.debug("Acknowledging message with delivery tag %s" % (
                 message.delivery_tag))
-            message.ack()
         return message
 
     def fetch_next_task(self):

setup.py

@@ -63,7 +63,7 @@ setup(
     zip_safe=False,
     install_requires=[
         'simplejson',
-        'carrot>=0.3.9',
+        'carrot>=0.4.0',
         'django',
     ],
     cmdclass = {"test": RunTests},