diff --git a/pyinfra/queue/async_manager.py b/pyinfra/queue/async_manager.py
index 75efd8e..9031e24 100644
--- a/pyinfra/queue/async_manager.py
+++ b/pyinfra/queue/async_manager.py
@@ -80,7 +80,7 @@ class AsyncQueueManager:
 
     async def is_ready(self) -> bool:
         await self.connect()
-        return await self.channel.is_open
+        return self.channel.is_initialized
 
     async def setup_exchanges(self) -> None:
         self.tenant_exchange = await self.channel.declare_exchange(
diff --git a/pyproject.toml b/pyproject.toml
index d56ab3e..d97d1f8 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pyinfra"
-version = "3.2.0"
+version = "3.2.1"
 description = ""
 authors = ["Team Research <research@knecon.com>"]
 license = "All rights reseverd"