[fix] reset delivery tag. fixes #98

mosquito · Jan 25, 2018 · 53f2922 · 53f2922
1 parent e7768c6
commit 53f2922
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/aio_pika/channel.py b/aio_pika/channel.py
@@ -151,6 +151,7 @@ def initialize(self, timeout=None) -> None:
                 raise RuntimeError("Can't initialize closed channel")
 
             self._channel = yield from self._create_channel(timeout)
+            self._delivery_tag = 0
 
     def _on_return_delivery(self, channel, method_frame, properties, body):
         f = self._confirmations.pop(int(properties.headers.get('delivery-tag')))

diff --git a/aio_pika/version.py b/aio_pika/version.py
@@ -7,7 +7,7 @@
 
 team_email = 'me@mosquito.su'
 
-version_info = (1, 9, 0)
+version_info = (1, 9, 1)
 
 __author__ = ", ".join("{} <{}>".format(*info) for info in author_info)
 __version__ = ".".join(map(str, version_info))