diff --git a/src/arroyopy/operator.py b/src/arroyopy/operator.py
index bea8a95..2e2795e 100644
--- a/src/arroyopy/operator.py
+++ b/src/arroyopy/operator.py
@@ -47,6 +47,6 @@ async def start(self):
                 for listener in self.listeners:
                     await listener.stop()
                 break
-            message = await self.queue.get()
+            message = await self.listener_queue.get()
             processed_message = await self.process(message)
             await self.publish(processed_message)