Merge pull request #80 from allo-media/master

v2.3.2

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2018-2019 Groupe Allo-Media
+Copyright (c) 2018-2024 Groupe Allo-Media
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -8,7 +8,7 @@
 
 The Allo-Media event-driven service architecture is language and framework independent and is described in the following document:
 
-*Blog post coming soon…*
+https://blog.uh.live/2020/02/17/an-event-drive-architecture/
 
 ### eventail.async_service
 

setup.py

@@ -5,7 +5,7 @@
 
 setup(
     name="eventail",
-    version="2.3.1",
+    version="2.3.2",
     url="https://github.com/allo-media/eventail",
     author="Allo-Media",
     author_email="[email protected]",

src/eventail/async_service/pika/base.py

@@ -482,7 +482,7 @@ def on_delivery_confirmation(self, method_frame: pika.frame.Method) -> None:
                     self.RETRY_DELAY, lambda args=self._deliveries[i]: self._emit(*args)
                 )
                 del self._deliveries[i]
-            # Pending acks that depend on at least one of those nacked publishes should be rescheduled too
+            # Pending rcv acks that depend on at least one of those nacked publishes should be rescheduled too
             low_bound = confirm_range[0]
             for i, (_, bound) in enumerate(self._pending_ack):
                 if bound >= low_bound:
@@ -497,6 +497,7 @@ def on_delivery_confirmation(self, method_frame: pika.frame.Method) -> None:
         # ACK only
         for i in confirm_range:
             del self._deliveries[i]
+        acks = 0
         if self._deliveries:
             low_bound = next(iter(self._deliveries.keys()))
             for i, (pending, bound) in enumerate(self._pending_ack):