* error handling

python-trio · Jan 18, 2023 · 62ca723 · 62ca723
1 parent 99a9236
commit 62ca723
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/async_amqp/channel.py b/async_amqp/channel.py
@@ -18,7 +18,7 @@
 from . import properties as amqp_properties
 from .envelope import Envelope, ReturnEnvelope
 from .future import Future
-from .exceptions import AmqpClosedConnection, SynchronizationError
+from .exceptions import AmqpClosedConnection, ChannelClosed, SynchronizationError
 
 logger = logging.getLogger(__name__)
 
@@ -64,7 +64,7 @@ async def __aexit__(self, *tb):
         with anyio.CancelScope(shield=True):
             try:
                 await self.channel.basic_cancel(self.consumer_tag)
-            except AmqpClosedConnection:
+            except (AmqpClosedConnection,ChannelClosed):
                 pass
         await self._q_w.aclose()
         await self._q_r.aclose()

diff --git a/debian/changelog b/debian/changelog
@@ -1,3 +1,9 @@
+async-amqp (0.2.14-1) unstable; urgency=medium
+
+  * error handling
+
+ -- Matthias Urlichs <[email protected]>  Wed, 18 Jan 2023 19:33:39 +0100
+
 async-amqp (0.2.13-1) unstable; urgency=medium
 
   * Buffer incoming data