[fix] add ChannelInvalidStateError exceptions instead of RuntimeError

mosquito · Nov 13, 2019 · 26ffef5 · 26ffef5
1 parent 5e735e0
commit 26ffef5
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 2 deletions.
diff --git a/aiormq/__init__.py b/aiormq/__init__.py
@@ -11,6 +11,7 @@
     AuthenticationError,
     ChannelAccessRefused,
     ChannelClosed,
+    ChannelInvalidStateError,
     ChannelLockedResource,
     ChannelNotFoundEntity,
     ChannelPreconditionFailed,
@@ -52,6 +53,7 @@
     'Channel',
     'ChannelAccessRefused',
     'ChannelClosed',
+    'ChannelInvalidStateError',
     'ChannelLockedResource',
     'ChannelNotFoundEntity',
     'ChannelPreconditionFailed',

diff --git a/aiormq/channel.py b/aiormq/channel.py
@@ -74,7 +74,7 @@ def __init__(self, connector, number,
     @property
     def lock(self):
         if self.is_closed:
-            raise RuntimeError('%r closed' % self)
+            raise exc.ChannelInvalidStateError('%r closed' % self)
 
         return self.__lock
 

diff --git a/aiormq/exceptions.py b/aiormq/exceptions.py
@@ -164,3 +164,7 @@ def __init__(self, message: DeliveredMessage, frame: spec.Frame, *args):
             message.delivery.routing_key,
             *args
         )
+
+
+class ChannelInvalidStateError(RuntimeError):
+    pass
diff --git a/aiormq/version.py b/aiormq/version.py
@@ -7,7 +7,7 @@
 
 team_email = '[email protected]'
 
-version_info = (3, 0, 1)
+version_info = (3, 1, 0)
 
 __author__ = ", ".join("{} <{}>".format(*info) for info in author_info)
 __version__ = ".".join(map(str, version_info))
-Original file line number
+Diff line change
@@ Expand Up @@
                 message.delivery.routing_key,
                 *args
             )
+    class ChannelInvalidStateError(RuntimeError):
+        pass