diff --git a/asyncamqp/channel.py b/asyncamqp/channel.py index 6dd30d6..53f3407 100644 --- a/asyncamqp/channel.py +++ b/asyncamqp/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 +from .exceptions import AmqpClosedConnection, SynchronizationError logger = logging.getLogger(__name__) @@ -253,7 +253,7 @@ async def close(self, reply_code=0, reply_text="Normal Shutdown"): async def close_ok(self, frame): try: w = self._get_waiter('close') - except asyncamqp.exceptions.SynchronizationError: + except SynchronizationError: pass else: await w.set_result(True)