diff options
| author | Brian Bernstein <bernie@athens.(none)> | 2011-10-26 14:09:55 -0400 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2011-11-27 17:53:09 +0000 |
| commit | 25993c9e0a8ae6aa2132af64a470d2fb6b9a3b5e (patch) | |
| tree | c23349297b850399f6dde44f97b7d691d3c16616 /kombu/transport/SQS.py | |
| parent | d44e2a26f2d52c940582c2f7672bb0f31dfb83ce (diff) | |
| download | kombu-25993c9e0a8ae6aa2132af64a470d2fb6b9a3b5e.tar.gz | |
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
Diffstat (limited to 'kombu/transport/SQS.py')
| -rw-r--r-- | kombu/transport/SQS.py | 3 |
1 files changed, 3 insertions, 0 deletions
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: |