浏览代码

Fixes bug that causes priority to not be set for messages.

Closes #708
Eran Rundstein 13 年之前
父节点
当前提交
f5c1364c8c
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      celery/app/amqp.py

+ 1 - 1
celery/app/amqp.py

@@ -190,7 +190,7 @@ class TaskProducer(Producer):
              immediate=immediate, routing_key=routing_key,
              serializer=serializer or self.serializer,
              compression=compression or self.compression,
-             retry=retry, retry_policy=_rp, delivery_mode=delivery_mode,
+             retry=retry, retry_policy=_rp, delivery_mode=delivery_mode, priority=priority,
              declare=[self.queues[queue]] if queue else [],
              **kwargs)