From 25993c9e0a8ae6aa2132af64a470d2fb6b9a3b5e Mon Sep 17 00:00:00 2001 From: Brian Bernstein Date: Wed, 26 Oct 2011 14:09:55 -0400 Subject: [PATCH] SQS Transport: Fix for KeyError on message acknowledgment-- (#73) Avoids duplicate keys on message delivery tags by using UUIds instead of a simple counter. Closes #73 --- kombu/transport/SQS.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index 01c0545d..dd2da307 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -285,6 +285,9 @@ class Channel(virtual.Channel): aws_secret_access_key=conninfo.password, port=conninfo.port) + def _next_delivery_tag(self): + return uuid() # See #73 + @property def sqs(self): if self._sqs is None: