diff --git a/apps/abstraction/main.py b/apps/abstraction/main.py
index ff142cd..40cf28b 100644
--- a/apps/abstraction/main.py
+++ b/apps/abstraction/main.py
@@ -296,7 +296,7 @@ async def mqtt_worker(config: dict[str, Any], redis_client: aioredis.Redis) -> N
             ) as client:
                 logger.info(f"Connected to MQTT broker as {unique_client_id}")
                 
-                async with client.messages() as messages:
+                async with client.messages as messages:
                     # Subscribe to topics for all devices
                     for device in devices.values():
                         device_id = device['device_id']