diff --git a/src/socketio/asyncio_aiopika_manager.py b/src/socketio/asyncio_aiopika_manager.py
index 9c99903..b92d6c0 100644
--- a/src/socketio/asyncio_aiopika_manager.py
+++ b/src/socketio/asyncio_aiopika_manager.py
@@ -55,7 +55,7 @@ class AsyncAioPikaManager(AsyncPubSubManager):  # pragma: no cover
         super().__init__(channel=channel, write_only=write_only, logger=logger)
 
     async def _connection(self):
-        if (self.aiopika_connection is None or self.aiopika_connection.is_closed is False):
+        if (self.aiopika_connection is None or self.aiopika_connection.is_closed is True):
             return await aio_pika.connect_robust(self.url)
         return self.aiopika_connection