Merge pull request #88 from peter-wimsey/errors-when-reconnecting

Do not attempt to reconnect channels if there is no connection
mosquito · Jan 3, 2018 · 525bc3d · 525bc3d
2 parents f9a6825 + 4f1c820
commit 525bc3d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/aio_pika/robust_connection.py b/aio_pika/robust_connection.py
@@ -94,10 +94,10 @@ def _on_connection_lost(self, future: asyncio.Future, connection: AsyncioConnect
     def connect(self):
         result = yield from super().connect()
 
-        for number, channel in self._channels.items():
-            yield from channel.on_reconnect(self, number)
-
         if self._connection:
+            for number, channel in self._channels.items():
+                yield from channel.on_reconnect(self, number)
+
             for callback in self._on_reconnect_callbacks:
                 callback(self)