More explicit SQS message checking. Closes #519.
This commit is contained in:
parent
b9df567445
commit
63296049f1
1 changed files with 2 additions and 0 deletions
|
|
@ -285,6 +285,8 @@ class SQSBackend(BaseBackend):
|
||||||
# queue.messages only contains visible messages
|
# queue.messages only contains visible messages
|
||||||
while True:
|
while True:
|
||||||
for message in queue.messages:
|
for message in queue.messages:
|
||||||
|
if not message.visible:
|
||||||
|
continue
|
||||||
message.mark_received(
|
message.mark_received(
|
||||||
visibility_timeout=queue.visibility_timeout
|
visibility_timeout=queue.visibility_timeout
|
||||||
)
|
)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue