From 74647ab21a86ceb73b4110a06943c92d0cb83ab7 Mon Sep 17 00:00:00 2001 From: chris erway Date: Wed, 19 Nov 2014 02:29:08 -0500 Subject: [PATCH] SQS: Set delivery tag to SQS message receipt handle --- kombu/transport/SQS.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index dc1243b9..e7488779 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -206,6 +206,8 @@ class Channel(virtual.Channel): payload['properties']['delivery_info'].update({ 'sqs_message': message, 'sqs_queue': queue, }) + # set delivery tag to SQS receipt handle + payload['properties']['delivery_tag'] = message.receipt_handle return payload def _messages_to_python(self, messages, queue):