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):