Merge pull request #12 from digitalfortress-dev/chore/allow-retries

chore: allow retries
digitalfortress-dev · May 14, 2024 · 8c6e902 · 8c6e902
2 parents 97800cb + 186d22a
commit 8c6e902
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "sqs-client"
-version = "0.1.5"
+version = "0.1.6"
 authors = [
   {name="Digital Fortress", email="[email protected]" },
 ]

diff --git a/sqs_client/client.py b/sqs_client/client.py
@@ -177,11 +177,10 @@ def subscribe(
                 for message in messages["Messages"]:
                     try:
                         callback(message)
+                        self.delete_message(queue_name, message)
                     except Exception as e:
                         exception(e)
 
-                    self.delete_message(queue_name, message)
-
     def publish(
         self,
         queue_name,