Merge branch 'cce/sqs_receipt_handle'

This commit is contained in:
Ask Solem 2015-02-12 00:40:49 +00:00
commit 41c774903b
1 changed files with 2 additions and 0 deletions

View File

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