async def _worker(self, worker_name: str):
    queues = [...]
    while self.running:
        for queue in queues:
            message = await queue.get(no_ack=False, fail=False)
            if message:
                # process message...
        await asyncio.sleep(0.1)  # ❌ Polls every 100ms even when empty

async def _worker(self, worker_name: str):
    queues = [
        await self.channel.declare_queue(self.queues[priority], durable=True)
        for priority in [QueuePriority.HIGH, QueuePriority.MEDIUM, QueuePriority.LOW]
    ]
    
    while self.running:
        try:
            done, pending = await asyncio.wait(
                [queue.get(no_ack=False) for queue in queues],
                return_when=asyncio.FIRST_COMPLETED,
                timeout=1.0
            )
            
            if not self.running:
                break
                
            for task in done:
                message = await task
                if message:
                    item = json.loads(message.body.decode())
                    await self._process_item(item, worker_name)
                    await message.ack()
                    
            for task in pending:
                task.cancel()
                
        except asyncio.CancelledError:
            return
        except Exception as e:
            logger.error(f"Worker {worker_name} error: {e}")
            await asyncio.sleep(1)