diff --git a/aio_pika/channel.py b/aio_pika/channel.py index 25bab2af..888c905b 100644 --- a/aio_pika/channel.py +++ b/aio_pika/channel.py @@ -93,6 +93,7 @@ async def close(self, exc=None): # noinspection PyTypeChecker channel = self._channel # type: aiormq.Channel + channel.on_return_callbacks.remove(self._on_return) self._channel = () await channel.close()